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 |
MessagePublication.Factory.createPublication(BusRuntime runtime,
Collection<Subscription> subscriptions,
Object message) |
IMessagePublication |
IMessagePublication.markScheduled() |
IMessagePublication |
MBassador.publishAsync(T message) |
IMessagePublication |
MBassador.publishAsync(T message,
long timeout,
TimeUnit unit) |
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) |
Constructor and Description |
---|
InternalPublicationError(Throwable cause,
String message,
IMessagePublication publication) |
PublicationError(Throwable cause,
String message,
IMessagePublication publication) |
Modifier and Type | Method and Description |
---|---|
IMessagePublication |
SyncAsyncPostCommand.asynchronously() |
IMessagePublication |
ISyncAsyncPublicationCommand.asynchronously()
Execute the message publication asynchronously.
|
IMessagePublication |
SyncAsyncPostCommand.asynchronously(long timeout,
TimeUnit unit) |
IMessagePublication |
ISyncAsyncPublicationCommand.asynchronously(long timeout,
TimeUnit unit)
Execute the message publication asynchronously.
|
Modifier and Type | Method and Description |
---|---|
void |
FilteredMessageDispatcher.dispatch(IMessagePublication publication,
Object message,
Iterable listeners) |
void |
MessageDispatcher.dispatch(IMessagePublication publication,
Object message,
Iterable listeners) |
void |
EnvelopedMessageDispatcher.dispatch(IMessagePublication publication,
Object message,
Iterable listeners) |
void |
IMessageDispatcher.dispatch(IMessagePublication publication,
Object message,
Iterable listeners)
Delivers the given message to the given set of listeners.
|
Modifier and Type | Method and Description |
---|---|
void |
Subscription.publish(IMessagePublication publication,
Object message) |
Copyright © 2016. All rights reserved.