- IHandlerInvocation<HANDLER,MESSAGE> - Interface in net.engio.mbassy.dispatch
-
A handler invocation encapsulates the logic that is used to invoke a single
message handler to process a given message.
- IMessageBus<T,P extends ISyncAsyncPublicationCommand> - Interface in net.engio.mbassy.bus.common
-
A message bus offers facilities for publishing messages to the message handlers of registered listeners.
- IMessageDispatcher - Interface in net.engio.mbassy.dispatch
-
A message dispatcher provides the functionality to deliver a single message
to a set of listeners.
- IMessageFilter<M> - Interface in net.engio.mbassy.listener
-
Message filters can be used to control what messages are delivered to a specific message handler.
- IMessagePublication - Interface in net.engio.mbassy.bus
-
A message publication is created for each asynchronous message dispatch.
- IncludeFilters - Annotation Type in net.engio.mbassy.listener
-
- InternalPublicationError - Class in net.engio.mbassy.bus.error
-
This type of publication error is used to communicate technical/library related errors as opposed to errors in client code, i.e.
- InternalPublicationError(Throwable, String, IMessagePublication) - Constructor for class net.engio.mbassy.bus.error.InternalPublicationError
-
- InternalPublicationError(Throwable, String) - Constructor for class net.engio.mbassy.bus.error.InternalPublicationError
-
- Invocation - Static variable in class net.engio.mbassy.listener.MessageHandler.Properties
-
- invoke(Object, Object, MessagePublication) - Method in class net.engio.mbassy.dispatch.AsynchronousHandlerInvocation
-
Invoke the message delivery logic of this handler
- invoke(HANDLER, MESSAGE, MessagePublication) - Method in interface net.engio.mbassy.dispatch.IHandlerInvocation
-
Invoke the message delivery logic of this handler
- invoke(Object, Object, MessagePublication) - Method in class net.engio.mbassy.dispatch.ReflectiveHandlerInvocation
-
Invoke the message delivery logic of this handler
- invoke(Object, Object, MessagePublication) - Method in class net.engio.mbassy.dispatch.SynchronizedHandlerInvocation
-
Invoke the message delivery logic of this handler
- Invoke - Enum in net.engio.mbassy.listener
-
Created with IntelliJ IDEA.
- IPredicate<T> - Interface in net.engio.mbassy.common
-
Created with IntelliJ IDEA.
- IPublicationCommand - Interface in net.engio.mbassy.bus.publication
-
A publication command is used as an intermediate object created by a call to the message bus' post method.
- IPublicationErrorHandler - Interface in net.engio.mbassy.bus.error
-
Publication error handlers are provided with a publication error every time an
error occurs during message publication.
- IPublicationErrorHandler.ConsoleLogger - Class in net.engio.mbassy.bus.error
-
The default error handler will simply log to standard out and
print the stack trace if available.
- isAsynchronous() - Method in class net.engio.mbassy.listener.MessageHandler
-
- IsAsynchronous - Static variable in class net.engio.mbassy.listener.MessageHandler.Properties
-
- isDeadMessage() - Method in interface net.engio.mbassy.bus.IMessagePublication
-
- isDeadMessage() - Method in class net.engio.mbassy.bus.MessagePublication
-
- isELAvailable() - Static method in class net.engio.mbassy.dispatch.el.ElFilter
-
- isEmpty() - Method in class net.engio.mbassy.common.AbstractConcurrentSet
-
- isEnveloped() - Method in class net.engio.mbassy.listener.MessageHandler
-
- ISetEntry<T> - Interface in net.engio.mbassy.common
-
Todo: Add javadoc
- isFiltered() - Method in class net.engio.mbassy.listener.MessageHandler
-
- isFilteredMessage() - Method in interface net.engio.mbassy.bus.IMessagePublication
-
- isFilteredMessage() - Method in class net.engio.mbassy.bus.MessagePublication
-
- isFinished() - Method in interface net.engio.mbassy.bus.IMessagePublication
-
- isFinished() - Method in class net.engio.mbassy.bus.MessagePublication
-
- isFromListener(Class) - Method in class net.engio.mbassy.listener.MessageHandler
-
- isFromListener(Class) - Method in class net.engio.mbassy.listener.MessageListener
-
- isRunning() - Method in interface net.engio.mbassy.bus.IMessagePublication
-
- isRunning() - Method in class net.engio.mbassy.bus.MessagePublication
-
- isScheduled() - Method in interface net.engio.mbassy.bus.IMessagePublication
-
- isScheduled() - Method in class net.engio.mbassy.bus.MessagePublication
-
- isSynchronized() - Method in class net.engio.mbassy.listener.MessageHandler
-
- IsSynchronized - Static variable in class net.engio.mbassy.listener.MessageHandler.Properties
-
- ISubscriptionContextAware - Interface in net.engio.mbassy.subscription
-
This interface marks components that have access to the subscription context.
- ISubscriptionManagerProvider - Interface in net.engio.mbassy.subscription
-
- ISyncAsyncPublicationCommand - Interface in net.engio.mbassy.bus.publication
-
- ISyncMessageBus<T,P extends IPublicationCommand> - Interface in net.engio.mbassy.bus.common
-
- iterator() - Method in class net.engio.mbassy.common.StrongConcurrentSet
-
- iterator() - Method in class net.engio.mbassy.common.WeakConcurrentSet
-
- setCause(Throwable) - Method in class net.engio.mbassy.bus.error.PublicationError
-
Assigns the cause of this PublicationError.
- setDispatcherThreadFactory(ThreadFactory) - Method in class net.engio.mbassy.bus.config.Feature.AsynchronousMessageDispatch
-
- setExecutor(ExecutorService) - Method in class net.engio.mbassy.bus.config.Feature.AsynchronousHandlerInvocation
-
- setHandler(Method) - Method in class net.engio.mbassy.bus.error.PublicationError
-
- setListener(Object) - Method in class net.engio.mbassy.bus.error.PublicationError
-
- setMessage(String) - Method in class net.engio.mbassy.bus.error.PublicationError
-
- setMessageQueue(BlockingQueue<IMessagePublication>) - Method in class net.engio.mbassy.bus.config.Feature.AsynchronousMessageDispatch
-
- setMetadataReader(MetadataReader) - Method in class net.engio.mbassy.bus.config.Feature.SyncPubSub
-
- setNumberOfMessageDispatchers(int) - Method in class net.engio.mbassy.bus.config.Feature.AsynchronousMessageDispatch
-
- setProperty(String, Object) - Method in class net.engio.mbassy.bus.config.BusConfiguration
-
Set a property which will be read by the message bus constructor.
- setPublication(IMessagePublication) - Method in class net.engio.mbassy.bus.error.PublicationError
-
- setPublicationFactory(MessagePublication.Factory) - Method in class net.engio.mbassy.bus.config.Feature.SyncPubSub
-
- setPublishedMessage(Object) - Method in class net.engio.mbassy.bus.error.PublicationError
-
- setSubscriptionFactory(SubscriptionFactory) - Method in class net.engio.mbassy.bus.config.Feature.SyncPubSub
-
- setSubscriptionManagerProvider(ISubscriptionManagerProvider) - Method in class net.engio.mbassy.bus.config.Feature.SyncPubSub
-
- shutdown() - Method in class net.engio.mbassy.bus.AbstractSyncAsyncMessageBus
-
- shutdown() - Method in interface net.engio.mbassy.bus.common.IMessageBus
-
Shutdown the bus such that it will stop delivering asynchronous messages.
- size() - Method in class net.engio.mbassy.common.AbstractConcurrentSet
-
- size() - Method in class net.engio.mbassy.subscription.Subscription
-
- StandardELResolutionContext - Class in net.engio.mbassy.dispatch.el
-
This ELContext implementation provides support for standard BeanEL resolution in conditional message handlers.
- StandardELResolutionContext(Object) - Constructor for class net.engio.mbassy.dispatch.el.StandardELResolutionContext
-
- StrongConcurrentSet<T> - Class in net.engio.mbassy.common
-
This implementation uses strong references to the elements.
- StrongConcurrentSet() - Constructor for class net.engio.mbassy.common.StrongConcurrentSet
-
- StrongConcurrentSet.StrongEntry<T> - Class in net.engio.mbassy.common
-
- subscribe(Object) - Method in class net.engio.mbassy.bus.AbstractPubSubSupport
-
- subscribe(Object) - Method in interface net.engio.mbassy.bus.common.PubSubSupport
-
Subscribe all handlers of the given listener.
- subscribe(Object) - Method in class net.engio.mbassy.subscription.Subscription
-
- subscribe(Object) - Method in class net.engio.mbassy.subscription.SubscriptionManager
-
- Subscription - Class in net.engio.mbassy.subscription
-
A subscription is a thread-safe container that manages exactly one message handler of all registered
message listeners of the same class, i.e.
- Subscription.Handle - Class in net.engio.mbassy.subscription
-
A handle exposes specific functionality of a subscription to be used by clients.
- SubscriptionByPriorityDesc - Static variable in class net.engio.mbassy.subscription.Subscription
-
- SubscriptionContext - Class in net.engio.mbassy.subscription
-
The subscription context holds all (meta)data/objects that are relevant to successfully publish
a message within a subscription.
- SubscriptionContext(BusRuntime, MessageHandler, Collection<IPublicationErrorHandler>) - Constructor for class net.engio.mbassy.subscription.SubscriptionContext
-
- SubscriptionFactory - Class in net.engio.mbassy.subscription
-
The subscription factory is used to create an empty subscription for specific message handler.
- SubscriptionFactory() - Constructor for class net.engio.mbassy.subscription.SubscriptionFactory
-
- SubscriptionManager - Class in net.engio.mbassy.subscription
-
The subscription managers responsibility is to consistently handle and synchronize the message listener subscription process.
- SubscriptionManager(MetadataReader, SubscriptionFactory, BusRuntime) - Constructor for class net.engio.mbassy.subscription.SubscriptionManager
-
- SubscriptionManagerProvider - Class in net.engio.mbassy.subscription
-
- SubscriptionManagerProvider() - Constructor for class net.engio.mbassy.subscription.SubscriptionManagerProvider
-
- SubtypesOnly() - Constructor for class net.engio.mbassy.listener.Filters.SubtypesOnly
-
- SyncAsyncPostCommand<T> - Class in net.engio.mbassy.bus.publication
-
This post command provides access to standard synchronous and asynchronous dispatch
- SyncAsyncPostCommand(MBassador<T>, T) - Constructor for class net.engio.mbassy.bus.publication.SyncAsyncPostCommand
-
- Synchronized - Annotation Type in net.engio.mbassy.listener
-
A handler marked with this annotation is guaranteed to be invoked in a thread-safe manner, that is, no
other running message publication will be able to invoke this or any other synchronized handler of the same
listener until the handler completed.
- SynchronizedHandlerInvocation - Class in net.engio.mbassy.dispatch
-
Synchronizes message handler invocations for all handlers that specify @Synchronized
- SynchronizedHandlerInvocation(IHandlerInvocation) - Constructor for class net.engio.mbassy.dispatch.SynchronizedHandlerInvocation
-
- SyncMessageBus<T> - Class in net.engio.mbassy.bus
-
A message bus implementation that offers only synchronous message publication.
- SyncMessageBus() - Constructor for class net.engio.mbassy.bus.SyncMessageBus
-
Default constructor using default setup.
- SyncMessageBus(IPublicationErrorHandler) - Constructor for class net.engio.mbassy.bus.SyncMessageBus
-
Construct with default settings and specified publication error handler
- SyncMessageBus(BusConfiguration) - Constructor for class net.engio.mbassy.bus.SyncMessageBus
-
Construct with fully specified configuration
- SyncMessageBus.SyncPostCommand - Class in net.engio.mbassy.bus
-
- SyncPostCommand(T) - Constructor for class net.engio.mbassy.bus.SyncMessageBus.SyncPostCommand
-
- SyncPubSub() - Constructor for class net.engio.mbassy.bus.config.Feature.SyncPubSub
-