Uses of Interface
net.engio.mbassy.bus.IMessagePublication
-
Packages that use IMessagePublication 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 -
-
Uses of IMessagePublication in net.engio.mbassy.bus
Classes in net.engio.mbassy.bus that implement IMessagePublication Modifier and Type Class Description class
MessagePublication
A message publication is created for each asynchronous message dispatch.Fields in net.engio.mbassy.bus with type parameters of type IMessagePublication Modifier and Type Field Description private java.util.concurrent.BlockingQueue<IMessagePublication>
AbstractSyncAsyncMessageBus. pendingMessages
Methods in net.engio.mbassy.bus that return IMessagePublication Modifier and Type Method Description protected IMessagePublication
AbstractSyncAsyncMessageBus. addAsynchronousPublication(MessagePublication publication)
protected IMessagePublication
AbstractSyncAsyncMessageBus. addAsynchronousPublication(MessagePublication publication, long timeout, java.util.concurrent.TimeUnit unit)
IMessagePublication
SyncMessageBus.SyncPostCommand. now()
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
SyncMessageBus. publish(T message)
IMessagePublication
MBassador. publishAsync(T message)
IMessagePublication
MBassador. publishAsync(T message, long timeout, java.util.concurrent.TimeUnit unit)
-
Uses of IMessagePublication in net.engio.mbassy.bus.common
Methods in net.engio.mbassy.bus.common that return IMessagePublication Modifier and Type Method Description IMessagePublication
PubSubSupport. publish(T message)
Synchronously publish a message to all registered listeners. -
Uses of IMessagePublication in net.engio.mbassy.bus.config
Fields in net.engio.mbassy.bus.config with type parameters of type IMessagePublication Modifier and Type Field Description private java.util.concurrent.BlockingQueue<IMessagePublication>
Feature.AsynchronousMessageDispatch. messageQueue
Methods in net.engio.mbassy.bus.config that return types with arguments of type IMessagePublication Modifier and Type Method Description java.util.concurrent.BlockingQueue<IMessagePublication>
Feature.AsynchronousMessageDispatch. getMessageQueue()
Method parameters in net.engio.mbassy.bus.config with type arguments of type IMessagePublication Modifier and Type Method Description Feature.AsynchronousMessageDispatch
Feature.AsynchronousMessageDispatch. setMessageQueue(java.util.concurrent.BlockingQueue<IMessagePublication> pendingMessages)
-
Uses of IMessagePublication in net.engio.mbassy.bus.error
Fields in net.engio.mbassy.bus.error declared as IMessagePublication Modifier and Type Field Description private IMessagePublication
PublicationError. publication
Methods in net.engio.mbassy.bus.error with parameters of type IMessagePublication Modifier and Type Method Description PublicationError
PublicationError. setPublication(IMessagePublication publication)
Constructors in net.engio.mbassy.bus.error with parameters of type IMessagePublication Constructor Description InternalPublicationError(java.lang.Throwable cause, java.lang.String message, IMessagePublication publication)
PublicationError(java.lang.Throwable cause, java.lang.String errorMsg, java.lang.reflect.Method handler, java.lang.Object listener, IMessagePublication publication)
Compound constructor, creating a PublicationError from the supplied objects.PublicationError(java.lang.Throwable cause, java.lang.String errorMsg, IMessagePublication publication)
-
Uses of IMessagePublication in net.engio.mbassy.bus.publication
Methods in net.engio.mbassy.bus.publication that return IMessagePublication Modifier and Type Method Description IMessagePublication
ISyncAsyncPublicationCommand. asynchronously()
Execute the message publication asynchronously.IMessagePublication
ISyncAsyncPublicationCommand. asynchronously(long timeout, java.util.concurrent.TimeUnit unit)
Execute the message publication asynchronously.IMessagePublication
SyncAsyncPostCommand. asynchronously()
IMessagePublication
SyncAsyncPostCommand. asynchronously(long timeout, java.util.concurrent.TimeUnit unit)
IMessagePublication
IPublicationCommand. now()
Execute the message publication immediately.IMessagePublication
SyncAsyncPostCommand. now()
-