| Package | Description |
|---|---|
| net.engio.mbassy.bus | |
| net.engio.mbassy.bus.common | |
| net.engio.mbassy.bus.config | |
| net.engio.mbassy.bus.error | |
| net.engio.mbassy.bus.publication |
| Modifier and Type | Class and Description |
|---|---|
class |
MessagePublication
A message publication is created for each asynchronous message dispatch.
|
| Modifier and Type | Method and Description |
|---|---|
IMessagePublication |
SyncMessageBus.SyncPostCommand.now() |
IMessagePublication |
SyncMessageBus.publish(T message) |
IMessagePublication |
MBassador.publish(T message)
Synchronously publish a message to all registered listeners (this includes listeners defined for super types)
The call blocks until every messageHandler has processed the message.
|
IMessagePublication |
MBassador.publishAsync(T message) |
IMessagePublication |
MBassador.publishAsync(T message,
long timeout,
TimeUnit unit) |
| Modifier and Type | Method and Description |
|---|---|
IMessagePublication |
PubSubSupport.publish(T message)
Synchronously publish a message to all registered listeners.
|
| Modifier and Type | Method and Description |
|---|---|
BlockingQueue<IMessagePublication> |
Feature.AsynchronousMessageDispatch.getMessageQueue() |
| Modifier and Type | Method and Description |
|---|---|
Feature.AsynchronousMessageDispatch |
Feature.AsynchronousMessageDispatch.setMessageQueue(BlockingQueue<IMessagePublication> pendingMessages) |
| Modifier and Type | Method and Description |
|---|---|
PublicationError |
PublicationError.setPublication(IMessagePublication publication) |
| Constructor and Description |
|---|
InternalPublicationError(Throwable cause,
String message,
IMessagePublication publication) |
PublicationError(Throwable cause,
String errorMsg,
IMessagePublication publication) |
PublicationError(Throwable cause,
String errorMsg,
Method handler,
Object listener,
IMessagePublication publication)
Compound constructor, creating a PublicationError from the supplied objects.
|
| Modifier and Type | Method and Description |
|---|---|
IMessagePublication |
ISyncAsyncPublicationCommand.asynchronously()
Execute the message publication asynchronously.
|
IMessagePublication |
SyncAsyncPostCommand.asynchronously() |
IMessagePublication |
ISyncAsyncPublicationCommand.asynchronously(long timeout,
TimeUnit unit)
Execute the message publication asynchronously.
|
IMessagePublication |
SyncAsyncPostCommand.asynchronously(long timeout,
TimeUnit unit) |
IMessagePublication |
IPublicationCommand.now()
Execute the message publication immediately.
|
IMessagePublication |
SyncAsyncPostCommand.now() |
Copyright © 2018. All rights reserved.