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.