| Package | Description |
|---|---|
| net.engio.mbassy.bus | |
| net.engio.mbassy.dispatch | |
| net.engio.mbassy.subscription |
| Modifier and Type | Method and Description |
|---|---|
MessagePublication |
MessagePublication.Factory.createPublication(BusRuntime runtime,
Collection<Subscription> subscriptions,
Object message) |
MessagePublication |
MessagePublication.markScheduled() |
| Modifier and Type | Method and Description |
|---|---|
void |
EnvelopedMessageDispatcher.dispatch(MessagePublication publication,
Object message,
Iterable listeners) |
void |
IMessageDispatcher.dispatch(MessagePublication publication,
Object message,
Iterable listeners)
Delivers the given message to the given set of listeners.
|
void |
MessageDispatcher.dispatch(MessagePublication publication,
Object message,
Iterable listeners) |
void |
FilteredMessageDispatcher.dispatch(MessagePublication publication,
Object message,
Iterable listeners) |
void |
IHandlerInvocation.invoke(HANDLER handler,
MESSAGE message,
MessagePublication publication)
Invoke the message delivery logic of this handler
|
void |
AsynchronousHandlerInvocation.invoke(Object listener,
Object message,
MessagePublication publication)
Invoke the message delivery logic of this handler
|
void |
SynchronizedHandlerInvocation.invoke(Object listener,
Object message,
MessagePublication publication)
Invoke the message delivery logic of this handler
|
void |
ReflectiveHandlerInvocation.invoke(Object listener,
Object message,
MessagePublication publication)
Invoke the message delivery logic of this handler
|
| Modifier and Type | Method and Description |
|---|---|
void |
Subscription.publish(MessagePublication publication,
Object message) |
Copyright © 2018. All rights reserved.