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 classMessagePublicationA 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. pendingMessagesMethods in net.engio.mbassy.bus that return IMessagePublication Modifier and Type Method Description protected IMessagePublicationAbstractSyncAsyncMessageBus. addAsynchronousPublication(MessagePublication publication)protected IMessagePublicationAbstractSyncAsyncMessageBus. addAsynchronousPublication(MessagePublication publication, long timeout, java.util.concurrent.TimeUnit unit)IMessagePublicationSyncMessageBus.SyncPostCommand. now()IMessagePublicationMBassador. 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.IMessagePublicationSyncMessageBus. publish(T message)IMessagePublicationMBassador. publishAsync(T message)IMessagePublicationMBassador. 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 IMessagePublicationPubSubSupport. 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. messageQueueMethods 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.AsynchronousMessageDispatchFeature.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 IMessagePublicationPublicationError. publicationMethods in net.engio.mbassy.bus.error with parameters of type IMessagePublication Modifier and Type Method Description PublicationErrorPublicationError. 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 IMessagePublicationISyncAsyncPublicationCommand. asynchronously()Execute the message publication asynchronously.IMessagePublicationISyncAsyncPublicationCommand. asynchronously(long timeout, java.util.concurrent.TimeUnit unit)Execute the message publication asynchronously.IMessagePublicationSyncAsyncPostCommand. asynchronously()IMessagePublicationSyncAsyncPostCommand. asynchronously(long timeout, java.util.concurrent.TimeUnit unit)IMessagePublicationIPublicationCommand. now()Execute the message publication immediately.IMessagePublicationSyncAsyncPostCommand. now()
-