Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
A
- AbstractConcurrentSet<T> - Class in net.engio.mbassy.common
-
This data structure is optimized for non-blocking reads even when write operations occur.
- AbstractConcurrentSet(Map<T, ISetEntry<T>>) - Constructor for class net.engio.mbassy.common.AbstractConcurrentSet
- AbstractConcurrentSet.Entry<T> - Class in net.engio.mbassy.common
- AbstractPubSubSupport<T> - Class in net.engio.mbassy.bus
-
The base class for all message bus implementations.
- AbstractPubSubSupport(IBusConfiguration) - Constructor for class net.engio.mbassy.bus.AbstractPubSubSupport
- AbstractSubscriptionContextAware - Class in net.engio.mbassy.subscription
-
The base implementation for subscription context aware objects (mightily obvious :)
- AbstractSubscriptionContextAware(SubscriptionContext) - Constructor for class net.engio.mbassy.subscription.AbstractSubscriptionContextAware
- AbstractSyncAsyncMessageBus<T,
P> - Class in net.engio.mbassy.bus -
The base class for all message bus implementations with support for asynchronous message dispatch
- AbstractSyncAsyncMessageBus(IBusConfiguration) - Constructor for class net.engio.mbassy.bus.AbstractSyncAsyncMessageBus
- accepts(Object, SubscriptionContext) - Method in class net.engio.mbassy.dispatch.el.ElFilter
- accepts(Object, SubscriptionContext) - Method in class net.engio.mbassy.listener.Filters.RejectSubtypes
- accepts(Object, SubscriptionContext) - Method in class net.engio.mbassy.listener.Filters.SubtypesOnly
- accepts(M, SubscriptionContext) - Method in interface net.engio.mbassy.listener.IMessageFilter
-
Check whether the message matches some criteria
- acceptsSubtypes - Variable in class net.engio.mbassy.listener.MessageHandler
- acceptsSubtypes() - Method in class net.engio.mbassy.listener.MessageHandler
- AcceptSubtypes - Static variable in class net.engio.mbassy.listener.MessageHandler.Properties
- add(String, Object) - Method in class net.engio.mbassy.bus.BusRuntime
- add(Subscription) - Method in class net.engio.mbassy.bus.MessagePublication
- add(T) - Method in class net.engio.mbassy.common.AbstractConcurrentSet
- addAll(Collection<? extends T>) - Method in class net.engio.mbassy.common.AbstractConcurrentSet
- addAsynchronousPublication(MessagePublication) - Method in class net.engio.mbassy.bus.AbstractSyncAsyncMessageBus
- addAsynchronousPublication(MessagePublication, long, TimeUnit) - Method in class net.engio.mbassy.bus.AbstractSyncAsyncMessageBus
- addFeature(Feature) - Method in class net.engio.mbassy.bus.config.BusConfiguration
- addFeature(Feature) - Method in interface net.engio.mbassy.bus.config.IBusConfiguration
-
Add a feature to the given configuration, replacing any existing feature of the same type.
- addHandler(MessageHandler) - Method in class net.engio.mbassy.listener.MessageListener
- addHandlers(Collection<? extends MessageHandler>) - Method in class net.engio.mbassy.listener.MessageListener
- addPublicationErrorHandler(IPublicationErrorHandler) - Method in class net.engio.mbassy.bus.config.BusConfiguration
- addPublicationErrorHandler(IPublicationErrorHandler) - Method in interface net.engio.mbassy.bus.config.IBusConfiguration
-
Add a handler that will be called whenever a publication error occurs.
- AllMessageHandlers - Static variable in class net.engio.mbassy.listener.MetadataReader
- apply(T) - Method in interface net.engio.mbassy.common.IPredicate
- AsynchronousHandlerExecutor - Static variable in class net.engio.mbassy.bus.config.IBusConfiguration.Properties
- AsynchronousHandlerInvocation - Class in net.engio.mbassy.dispatch
-
This invocation will schedule the wrapped (decorated) invocation to be executed asynchronously
- AsynchronousHandlerInvocation() - Constructor for class net.engio.mbassy.bus.config.Feature.AsynchronousHandlerInvocation
- AsynchronousHandlerInvocation(IHandlerInvocation) - Constructor for class net.engio.mbassy.dispatch.AsynchronousHandlerInvocation
- asynchronously() - Method in interface net.engio.mbassy.bus.publication.ISyncAsyncPublicationCommand
-
Execute the message publication asynchronously.
- asynchronously() - Method in class net.engio.mbassy.bus.publication.SyncAsyncPostCommand
- asynchronously(long, TimeUnit) - Method in interface net.engio.mbassy.bus.publication.ISyncAsyncPublicationCommand
-
Execute the message publication asynchronously.
- asynchronously(long, TimeUnit) - Method in class net.engio.mbassy.bus.publication.SyncAsyncPostCommand
- Asynchronously - Enum constant in enum class net.engio.mbassy.listener.Invoke
- AsynchronousMessageDispatch() - Constructor for class net.engio.mbassy.bus.config.Feature.AsynchronousMessageDispatch
B
- belongsTo(Class) - Method in class net.engio.mbassy.subscription.Subscription
-
Check whether this subscription manages a message handler of the given listener class.
- buildDispatcher(SubscriptionContext, IHandlerInvocation) - Method in class net.engio.mbassy.subscription.SubscriptionFactory
- buildInvocationForHandler(SubscriptionContext) - Method in class net.engio.mbassy.subscription.SubscriptionFactory
- BusConfiguration - Class in net.engio.mbassy.bus.config
- BusConfiguration() - Constructor for class net.engio.mbassy.bus.config.BusConfiguration
- BusId - Static variable in class net.engio.mbassy.bus.config.IBusConfiguration.Properties
- BusRuntime - Class in net.engio.mbassy.bus
-
Message bus implementations potentially vary in the features they provide and consequently in the components and properties they expose.
- BusRuntime(PubSubSupport) - Constructor for class net.engio.mbassy.bus.BusRuntime
C
- cause - Variable in class net.engio.mbassy.bus.error.PublicationError
- cleanEL(String) - Static method in class net.engio.mbassy.listener.MessageHandler.Properties
- clear() - Method in class net.engio.mbassy.common.AbstractConcurrentSet
- clear() - Method in class net.engio.mbassy.common.AbstractConcurrentSet.Entry
- clear() - Method in interface net.engio.mbassy.common.ISetEntry
- collectFilters(Method, Handler) - Method in class net.engio.mbassy.listener.MetadataReader
- collectInterfaces(Class, Collection<Class>) - Static method in class net.engio.mbassy.common.ReflectionUtils
- condition - Variable in class net.engio.mbassy.listener.MessageHandler
- condition() - Element in annotation interface net.engio.mbassy.listener.Handler
-
Defines a filter condition as Expression Language.
- Condition - Static variable in class net.engio.mbassy.listener.MessageHandler.Properties
- ConfigurationError - Exception Class in net.engio.mbassy.bus.config
-
Configuration errors represent specific invalid configurations of a feature in a
IBusConfiguration
An invalid feature configuration is assumed to render the bus dysfunctional and as such is thrown as an unchecked exception. - ConfigurationError(String) - Constructor for exception class net.engio.mbassy.bus.config.ConfigurationError
- ConfigurationErrorHandler - Interface in net.engio.mbassy.bus.config
-
Respond to a
ConfigurationError
with any kind of action. - ConsoleLogger() - Constructor for class net.engio.mbassy.bus.error.IPublicationErrorHandler.ConsoleLogger
- ConsoleLogger(boolean) - Constructor for class net.engio.mbassy.bus.error.IPublicationErrorHandler.ConsoleLogger
- contains(Object) - Method in class net.engio.mbassy.common.AbstractConcurrentSet
- contains(Object) - Method in class net.engio.mbassy.subscription.Subscription
-
Check whether this subscriptions manages the given listener instance.
- contains(String) - Method in class net.engio.mbassy.bus.BusRuntime
- containsAll(Collection<?>) - Method in class net.engio.mbassy.common.AbstractConcurrentSet
- containsOverridingMethod(Method[], Method) - Static method in class net.engio.mbassy.common.ReflectionUtils
- context - Variable in class net.engio.mbassy.subscription.AbstractSubscriptionContextAware
- context - Variable in class net.engio.mbassy.subscription.Subscription
- Create(Method, Handler, IMessageFilter[], MessageListener) - Static method in class net.engio.mbassy.listener.MessageHandler.Properties
-
Create the property map for the
MessageHandler
constructor using the default objects. - createBaseHandlerInvocation(SubscriptionContext) - Method in class net.engio.mbassy.subscription.SubscriptionFactory
- createEntry(T, AbstractConcurrentSet.Entry<T>) - Method in class net.engio.mbassy.common.AbstractConcurrentSet
- createEntry(T, AbstractConcurrentSet.Entry<T>) - Method in class net.engio.mbassy.common.StrongConcurrentSet
- createEntry(T, AbstractConcurrentSet.Entry<T>) - Method in class net.engio.mbassy.common.WeakConcurrentSet
- createManager(MetadataReader, SubscriptionFactory, BusRuntime) - Method in interface net.engio.mbassy.subscription.ISubscriptionManagerProvider
- createManager(MetadataReader, SubscriptionFactory, BusRuntime) - Method in class net.engio.mbassy.subscription.SubscriptionManagerProvider
- createMessagePublication(T) - Method in class net.engio.mbassy.bus.AbstractPubSubSupport
- createPublication(BusRuntime, Collection<Subscription>, Object) - Method in class net.engio.mbassy.bus.MessagePublication.Factory
- createSubscription(BusRuntime, MessageHandler) - Method in class net.engio.mbassy.subscription.SubscriptionFactory
D
- DeadMessage - Class in net.engio.mbassy.bus.common
-
The dead message event is published whenever no message handlers could be found for a given message publication.
- DeadMessage(Object) - Constructor for class net.engio.mbassy.bus.common.DeadMessage
- Default() - Static method in class net.engio.mbassy.bus.config.Feature.AsynchronousHandlerInvocation
- Default() - Static method in class net.engio.mbassy.bus.config.Feature.AsynchronousMessageDispatch
- Default() - Static method in class net.engio.mbassy.bus.config.Feature.SyncPubSub
- Default(int, int) - Static method in class net.engio.mbassy.bus.config.Feature.AsynchronousHandlerInvocation
- delegate - Variable in class net.engio.mbassy.dispatch.AsynchronousHandlerInvocation
- delegate - Variable in class net.engio.mbassy.dispatch.DelegatingMessageDispatcher
- delegate - Variable in class net.engio.mbassy.dispatch.SynchronizedHandlerInvocation
- DelegatingMessageDispatcher - Class in net.engio.mbassy.dispatch
-
A delegating dispatcher wraps additional logic around a given delegate.
- DelegatingMessageDispatcher(IMessageDispatcher) - Constructor for class net.engio.mbassy.dispatch.DelegatingMessageDispatcher
- delivery() - Element in annotation interface net.engio.mbassy.listener.Handler
-
Define the mode in which a message is delivered to each listener.
- dispatch(MessagePublication, Object, Iterable) - Method in class net.engio.mbassy.dispatch.EnvelopedMessageDispatcher
- dispatch(MessagePublication, Object, Iterable) - Method in class net.engio.mbassy.dispatch.FilteredMessageDispatcher
- dispatch(MessagePublication, Object, Iterable) - Method in interface net.engio.mbassy.dispatch.IMessageDispatcher
-
Delivers the given message to the given set of listeners.
- dispatch(MessagePublication, Object, Iterable) - Method in class net.engio.mbassy.dispatch.MessageDispatcher
- dispatched - Variable in class net.engio.mbassy.bus.MessagePublication
- dispatcher - Variable in class net.engio.mbassy.subscription.Subscription
- dispatchers - Variable in class net.engio.mbassy.bus.AbstractSyncAsyncMessageBus
- dispatcherThreadFactory - Variable in class net.engio.mbassy.bus.config.Feature.AsynchronousMessageDispatch
E
- ELFactory - Static variable in class net.engio.mbassy.dispatch.el.ElFilter.ExpressionFactoryHolder
- ELFactory() - Static method in class net.engio.mbassy.dispatch.el.ElFilter
- ElFilter - Class in net.engio.mbassy.dispatch.el
-
A filter that will use a expression from the handler annotation and parse it as EL.
- ElFilter() - Constructor for class net.engio.mbassy.dispatch.el.ElFilter
- ElFilter.ExpressionFactoryHolder - Class in net.engio.mbassy.dispatch.el
- enabled() - Element in annotation interface net.engio.mbassy.listener.Handler
-
Enable or disable the handler.
- entries - Variable in class net.engio.mbassy.common.AbstractConcurrentSet
- Entry() - Constructor for class net.engio.mbassy.common.AbstractConcurrentSet.Entry
- Entry(AbstractConcurrentSet.Entry<T>) - Constructor for class net.engio.mbassy.common.AbstractConcurrentSet.Entry
- Enveloped - Annotation Interface in net.engio.mbassy.listener
-
Configure a handler to receive an enveloped message as a wrapper around the source message.
- Enveloped - Static variable in class net.engio.mbassy.listener.MessageHandler.Properties
- EnvelopedMessageDispatcher - Class in net.engio.mbassy.dispatch
-
The enveloped dispatcher will wrap published messages in an envelope before passing them to their configured dispatcher.
- EnvelopedMessageDispatcher(IMessageDispatcher) - Constructor for class net.engio.mbassy.dispatch.EnvelopedMessageDispatcher
- equals(Object) - Method in class net.engio.mbassy.common.AbstractConcurrentSet
- error - Variable in class net.engio.mbassy.bus.MessagePublication
- ERROR_HANDLER_MSG - Static variable in class net.engio.mbassy.bus.AbstractPubSubSupport
- errorHandlers - Variable in class net.engio.mbassy.bus.AbstractPubSubSupport
- errorHandlers - Variable in class net.engio.mbassy.subscription.SubscriptionContext
- ErrorHandlingSupport - Interface in net.engio.mbassy.bus.common
-
Publication errors may occur at various points of time during message delivery.
- errorMsg - Variable in class net.engio.mbassy.bus.error.PublicationError
- evalExpression(String, StandardELResolutionContext, SubscriptionContext, Object) - Method in class net.engio.mbassy.dispatch.el.ElFilter
- execute() - Method in interface net.engio.mbassy.bus.IMessagePublication
- execute() - Method in class net.engio.mbassy.bus.MessagePublication
- executor - Variable in class net.engio.mbassy.bus.AbstractSyncAsyncMessageBus
- executor - Variable in class net.engio.mbassy.bus.config.Feature.AsynchronousHandlerInvocation
- executor - Variable in class net.engio.mbassy.dispatch.AsynchronousHandlerInvocation
- ExpressionFactoryHolder() - Constructor for class net.engio.mbassy.dispatch.el.ElFilter.ExpressionFactoryHolder
F
- Factory() - Constructor for class net.engio.mbassy.bus.MessagePublication.Factory
- Feature - Interface in net.engio.mbassy.bus.config
-
A feature defines the configuration of a specific functionality of a message bus.
- Feature.AsynchronousHandlerInvocation - Class in net.engio.mbassy.bus.config
- Feature.AsynchronousMessageDispatch - Class in net.engio.mbassy.bus.config
- Feature.SyncPubSub - Class in net.engio.mbassy.bus.config
- filter - Variable in class net.engio.mbassy.dispatch.FilteredMessageDispatcher
- filter - Variable in class net.engio.mbassy.listener.MessageHandler
- Filter - Annotation Interface in net.engio.mbassy.listener
-
The filter annotation is used to add filters to message listeners.
- Filter - Static variable in class net.engio.mbassy.listener.MessageHandler.Properties
- filterCache - Variable in class net.engio.mbassy.listener.MetadataReader
- FilteredMessage - Class in net.engio.mbassy.bus.common
-
A filtered message event is published when there have been matching subscriptions for a given message publication but configured filters prevented the message from being delivered to any of the handlers.
- FilteredMessage(Object) - Constructor for class net.engio.mbassy.bus.common.FilteredMessage
- FilteredMessageDispatcher - Class in net.engio.mbassy.dispatch
-
A dispatcher that implements message filtering based on the filter configuration of the associated message handler.
- FilteredMessageDispatcher(IMessageDispatcher) - Constructor for class net.engio.mbassy.dispatch.FilteredMessageDispatcher
- filters() - Element in annotation interface net.engio.mbassy.listener.Handler
-
Add any numbers of filters to the handler.
- Filters - Class in net.engio.mbassy.listener
-
A set of standard filters for common use cases.
- Filters() - Constructor for class net.engio.mbassy.listener.Filters
- Filters.RejectSubtypes - Class in net.engio.mbassy.listener
-
This filter will only accept messages of the exact same type as specified for the handler.
- Filters.SubtypesOnly - Class in net.engio.mbassy.listener
-
This filter will only accept messages that are real subtypes of the specified message types handled by the message handler.
- finalize() - Method in class net.engio.mbassy.bus.AbstractSyncAsyncMessageBus
- Finished - Enum constant in enum class net.engio.mbassy.bus.MessagePublication.State
- ForMessage(Class<?>) - Static method in class net.engio.mbassy.listener.MessageListener
- functionMapper - Variable in class net.engio.mbassy.dispatch.el.StandardELResolutionContext
G
- GenericMessagePublicationSupport<T,
P> - Interface in net.engio.mbassy.bus.common -
This interface is meant to be implemented by different bus implementations to offer a consistent way to plugin different methods of message publication.
- get(String) - Method in class net.engio.mbassy.bus.BusRuntime
- getAnnotation(Class<A>) - Method in class net.engio.mbassy.listener.MessageHandler
- getAnnotation(AnnotatedElement, Class<A>) - Static method in class net.engio.mbassy.common.ReflectionUtils
- getAnnotation(AnnotatedElement, Class<A>, Set<AnnotatedElement>) - Static method in class net.engio.mbassy.common.ReflectionUtils
-
Searches for an Annotation of the given type on the class.
- getCause() - Method in class net.engio.mbassy.bus.error.PublicationError
- getCondition() - Method in class net.engio.mbassy.listener.MessageHandler
- getContext() - Method in class net.engio.mbassy.subscription.AbstractSubscriptionContextAware
- getContext() - Method in interface net.engio.mbassy.subscription.ISubscriptionContextAware
-
Get the subscription context associated with this object
- getDelegate() - Method in class net.engio.mbassy.dispatch.DelegatingMessageDispatcher
- getDispatcherThreadFactory() - Method in class net.engio.mbassy.bus.config.Feature.AsynchronousMessageDispatch
- getELFactory() - Static method in class net.engio.mbassy.dispatch.el.ElFilter.ExpressionFactoryHolder
-
********************************************************************** Get an implementation of the ExpressionFactory.
- getELResolver() - Method in class net.engio.mbassy.dispatch.el.StandardELResolutionContext
-
The resolver for the event object.
- getError() - Method in interface net.engio.mbassy.bus.IMessagePublication
- getError() - Method in class net.engio.mbassy.bus.MessagePublication
- getErrorHandlers() - Method in class net.engio.mbassy.subscription.SubscriptionContext
-
Get the error handlers registered with the enclosing bus.
- getExecutor() - Method in class net.engio.mbassy.bus.config.Feature.AsynchronousHandlerInvocation
- getFeature(Class<T>) - Method in class net.engio.mbassy.bus.config.BusConfiguration
- getFeature(Class<T>) - Method in interface net.engio.mbassy.bus.config.IBusConfiguration
-
Get a registered feature by its type (class).
- getFilter() - Method in class net.engio.mbassy.listener.MessageHandler
- getFilter(Method, Handler) - Method in class net.engio.mbassy.listener.MetadataReader
- getFunctionMapper() - Method in class net.engio.mbassy.dispatch.el.StandardELResolutionContext
- getHandle() - Method in class net.engio.mbassy.subscription.Subscription
- getHandledMessages() - Method in class net.engio.mbassy.listener.MessageHandler
- getHandledMessageTypes() - Method in class net.engio.mbassy.subscription.Subscription
- getHandler() - Method in class net.engio.mbassy.bus.error.PublicationError
- getHandler() - Method in class net.engio.mbassy.subscription.SubscriptionContext
-
Get the meta data that specifies the characteristics of the message handler that is associated with this context
- getHandlerInvocation() - Method in class net.engio.mbassy.listener.MessageHandler
- getHandlers() - Method in class net.engio.mbassy.listener.MessageListener
- getHandlers(IPredicate<MessageHandler>) - Method in class net.engio.mbassy.listener.MessageListener
- getInvocation() - Method in class net.engio.mbassy.dispatch.DelegatingMessageDispatcher
- getInvocation() - Method in interface net.engio.mbassy.dispatch.IMessageDispatcher
-
Get the handler invocation that will be used to deliver the message to each listener.
- getInvocation() - Method in class net.engio.mbassy.dispatch.MessageDispatcher
- getKeys() - Method in class net.engio.mbassy.bus.BusRuntime
- getListener() - Method in class net.engio.mbassy.bus.error.PublicationError
- getListerDefinition() - Method in class net.engio.mbassy.listener.MessageListener
- getMessage() - Method in class net.engio.mbassy.bus.common.PublicationEvent
- getMessage() - Method in class net.engio.mbassy.bus.error.PublicationError
- getMessage() - Method in interface net.engio.mbassy.bus.IMessagePublication
- getMessage() - Method in class net.engio.mbassy.bus.MessagePublication
- getMessage() - Method in class net.engio.mbassy.subscription.MessageEnvelope
- getMessageListener(Class) - Method in class net.engio.mbassy.listener.MetadataReader
- getMessageQueue() - Method in class net.engio.mbassy.bus.config.Feature.AsynchronousMessageDispatch
- getMetadataReader() - Method in class net.engio.mbassy.bus.config.Feature.SyncPubSub
- getMethod() - Method in class net.engio.mbassy.listener.MessageHandler
- getMethods(IPredicate<Method>, Class<?>) - Static method in class net.engio.mbassy.common.ReflectionUtils
- getMethods(IPredicate<Method>, Class<?>, ArrayList<Method>) - Static method in class net.engio.mbassy.common.ReflectionUtils
- getNumberOfMessageDispatchers() - Method in class net.engio.mbassy.bus.config.Feature.AsynchronousMessageDispatch
- getOverridingMethod(Method, Class) - Static method in class net.engio.mbassy.common.ReflectionUtils
-
Traverses the class hierarchy upwards, starting at the given subclass, looking for an override of the given methods -> finds the bottom most override of the given method if any exists
- getPriority() - Method in class net.engio.mbassy.listener.MessageHandler
- getPriority() - Method in class net.engio.mbassy.subscription.Subscription
- getProperty(String, T) - Method in class net.engio.mbassy.bus.config.BusConfiguration
- getProperty(String, T) - Method in interface net.engio.mbassy.bus.config.IBusConfiguration
-
Read a property from this configuration.
- getProvider() - Method in class net.engio.mbassy.bus.BusRuntime
- getPublicationFactory() - Method in class net.engio.mbassy.bus.AbstractPubSubSupport
- getPublicationFactory() - Method in class net.engio.mbassy.bus.config.Feature.SyncPubSub
-
The message publication factory is used to wrap a published message in a
MessagePublication
for processing. - getPublishedMessage() - Method in class net.engio.mbassy.bus.error.PublicationError
- getRegisteredErrorHandlers() - Method in class net.engio.mbassy.bus.AbstractPubSubSupport
- getRegisteredErrorHandlers() - Method in interface net.engio.mbassy.bus.common.ErrorHandlingSupport
-
Get all registered instance of
IPublicationErrorHandler
- getRegisteredPublicationErrorHandlers() - Method in class net.engio.mbassy.bus.config.BusConfiguration
- getRegisteredPublicationErrorHandlers() - Method in interface net.engio.mbassy.bus.config.IBusConfiguration
-
Get an unmodifiable collection of all registered publication error handlers
- getRuntime() - Method in class net.engio.mbassy.bus.AbstractPubSubSupport
- getRuntime() - Method in interface net.engio.mbassy.bus.common.RuntimeProvider
- getRuntime() - Method in class net.engio.mbassy.subscription.SubscriptionContext
- getSubscriptionFactory() - Method in class net.engio.mbassy.bus.config.Feature.SyncPubSub
- getSubscriptionManagerProvider() - Method in class net.engio.mbassy.bus.config.Feature.SyncPubSub
- getSubscriptionsByListener(Object) - Method in class net.engio.mbassy.subscription.SubscriptionManager
- getSubscriptionsByMessageType(Class) - Method in class net.engio.mbassy.bus.AbstractPubSubSupport
- getSubscriptionsByMessageType(Class) - Method in class net.engio.mbassy.subscription.SubscriptionManager
- getSuperTypes(Class) - Static method in class net.engio.mbassy.common.ReflectionUtils
-
Collect all directly and indirectly related super types (classes and interfaces) of a given class.
- getValue() - Method in interface net.engio.mbassy.common.ISetEntry
- getValue() - Method in class net.engio.mbassy.common.StrongConcurrentSet.StrongEntry
- getValue() - Method in class net.engio.mbassy.common.WeakConcurrentSet.WeakEntry
- getVariableMapper() - Method in class net.engio.mbassy.dispatch.el.StandardELResolutionContext
H
- handle(ConfigurationError) - Method in interface net.engio.mbassy.bus.config.ConfigurationErrorHandler
-
Called when a misconfiguration is detected on a
IBusConfiguration
- Handle() - Constructor for class net.engio.mbassy.subscription.Subscription.Handle
- handledMessages - Variable in class net.engio.mbassy.listener.MessageHandler
- HandledMessages - Static variable in class net.engio.mbassy.listener.MessageHandler.Properties
- handleError(PublicationError) - Method in class net.engio.mbassy.bus.error.IPublicationErrorHandler.ConsoleLogger
-
Handle the given publication error.
- handleError(PublicationError) - Method in interface net.engio.mbassy.bus.error.IPublicationErrorHandler
-
Handle the given publication error.
- handleError(PublicationError) - Method in class net.engio.mbassy.subscription.SubscriptionContext
- handlePublicationError(PublicationError) - Method in class net.engio.mbassy.bus.AbstractPubSubSupport
- handlePublicationError(MessagePublication, PublicationError) - Method in class net.engio.mbassy.dispatch.HandlerInvocation
- handler - Variable in class net.engio.mbassy.bus.error.PublicationError
- handler - Variable in class net.engio.mbassy.listener.MessageHandler
- handler - Variable in class net.engio.mbassy.subscription.SubscriptionContext
- Handler - Annotation Interface in net.engio.mbassy.listener
-
Mark any method of any class(=listener) as a message handler and configure the handler using different properties.
- HandlerInvocation<HANDLER,
MESSAGE> - Class in net.engio.mbassy.dispatch -
This is the base class for handler invocations that already implements all context related methods only leaving the implementation of the actual invocation mechanism to the concrete subclass.
- HandlerInvocation(SubscriptionContext) - Constructor for class net.engio.mbassy.dispatch.HandlerInvocation
- HandlerMethod - Static variable in class net.engio.mbassy.listener.MessageHandler.Properties
- handlers - Variable in class net.engio.mbassy.listener.MessageListener
- handles(Class<?>) - Method in class net.engio.mbassy.listener.MessageListener
- handlesMessage(Class<?>) - Method in class net.engio.mbassy.listener.MessageHandler
- handlesMessageType(Class<?>) - Method in class net.engio.mbassy.subscription.Subscription
-
Check whether this subscription manages a specific message type.
- hasError() - Method in interface net.engio.mbassy.bus.IMessagePublication
- hasError() - Method in class net.engio.mbassy.bus.MessagePublication
- hashCode() - Method in class net.engio.mbassy.common.AbstractConcurrentSet
- hasPendingMessages() - Method in class net.engio.mbassy.bus.AbstractSyncAsyncMessageBus
- hasPendingMessages() - Method in interface net.engio.mbassy.bus.common.IMessageBus
-
Check whether any asynchronous message publications are pending to be processed
- hasProperty(String) - Method in class net.engio.mbassy.bus.config.BusConfiguration
- hasProperty(String) - Method in interface net.engio.mbassy.bus.config.IBusConfiguration
-
Check whether a property has been set.
- head - Variable in class net.engio.mbassy.common.AbstractConcurrentSet
I
- IBusConfiguration - Interface in net.engio.mbassy.bus.config
-
The configuration of message bus instances is feature driven, e.g.
- IBusConfiguration.Properties - Class in net.engio.mbassy.bus.config
-
A collection of properties commonly used by different parts of the library.
- id - Static variable in class net.engio.mbassy.common.AbstractConcurrentSet
- id - Variable in class net.engio.mbassy.subscription.Subscription
- ID - Variable in class net.engio.mbassy.common.AbstractConcurrentSet
- 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> - 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 Interface in net.engio.mbassy.listener
-
The include filters directive can be used to add multiple
Filter
s to a singleannotation type
. - initDispatcherThreads(Feature.AsynchronousMessageDispatch) - Method in class net.engio.mbassy.bus.AbstractSyncAsyncMessageBus
- Initial - Enum constant in enum class net.engio.mbassy.bus.MessagePublication.State
- insert(T) - Method in class net.engio.mbassy.common.AbstractConcurrentSet
-
Inserts a new element at the head of the set.
- 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) - Constructor for class net.engio.mbassy.bus.error.InternalPublicationError
- InternalPublicationError(Throwable, String, IMessagePublication) - Constructor for class net.engio.mbassy.bus.error.InternalPublicationError
- invocation - Variable in class net.engio.mbassy.dispatch.MessageDispatcher
- invocation - Variable in class net.engio.mbassy.listener.MessageHandler
- invocation() - Element in annotation interface net.engio.mbassy.listener.Handler
-
Each handler call is implemented as an invocation object that implements the invocation mechanism.
- Invocation - Static variable in class net.engio.mbassy.listener.MessageHandler.Properties
- invocationMode - Variable in class net.engio.mbassy.listener.MessageHandler
- InvocationMode - Static variable in class net.engio.mbassy.listener.MessageHandler.Properties
- 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.AsynchronousHandlerInvocation
-
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 Class in net.engio.mbassy.listener
-
Created with IntelliJ IDEA.
- Invoke() - Constructor for enum class net.engio.mbassy.listener.Invoke
- 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
- 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
- isEnvelope - Variable in class net.engio.mbassy.listener.MessageHandler
- 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
- isOverriddenBy(Method, Method) - Static method in class net.engio.mbassy.common.ReflectionUtils
- 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 - Variable in class net.engio.mbassy.listener.MessageHandler
- 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
- isValidMessageHandler(Method) - Method in class net.engio.mbassy.listener.MetadataReader
- ISyncAsyncPublicationCommand - Interface in net.engio.mbassy.bus.publication
- ISyncMessageBus<T,
P> - 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
L
- listener - Variable in class net.engio.mbassy.bus.error.PublicationError
- Listener - Annotation Interface in net.engio.mbassy.listener
-
Configure how the listener is referenced in the event bus.
- Listener - Static variable in class net.engio.mbassy.listener.MessageHandler.Properties
- listenerAnnotation - Variable in class net.engio.mbassy.listener.MessageListener
- listenerConfig - Variable in class net.engio.mbassy.listener.MessageHandler
- listenerDefinition - Variable in class net.engio.mbassy.listener.MessageListener
- listeners - Variable in class net.engio.mbassy.subscription.Subscription
- lock - Variable in class net.engio.mbassy.common.AbstractConcurrentSet
M
- markDispatched() - Method in class net.engio.mbassy.bus.MessagePublication
- markError(PublicationError) - Method in class net.engio.mbassy.bus.MessagePublication
- markScheduled() - Method in class net.engio.mbassy.bus.MessagePublication
- mBassador - Variable in class net.engio.mbassy.bus.publication.SyncAsyncPostCommand
- MBassador<T> - Class in net.engio.mbassy.bus
- MBassador() - Constructor for class net.engio.mbassy.bus.MBassador
-
Default constructor using default setup.
- MBassador(IBusConfiguration) - Constructor for class net.engio.mbassy.bus.MBassador
-
Construct with fully specified configuration
- MBassador(IPublicationErrorHandler) - Constructor for class net.engio.mbassy.bus.MBassador
-
Construct with default settings and specified publication error handler
- message - Variable in exception class net.engio.mbassy.bus.config.ConfigurationError
- message - Variable in class net.engio.mbassy.bus.error.PublicationError
- message - Variable in class net.engio.mbassy.bus.MessagePublication
- message - Variable in class net.engio.mbassy.bus.publication.SyncAsyncPostCommand
- message - Variable in class net.engio.mbassy.bus.SyncMessageBus.SyncPostCommand
- message - Variable in class net.engio.mbassy.dispatch.el.StandardELResolutionContext
- message - Variable in class net.engio.mbassy.subscription.MessageEnvelope
- MessageBusException - Exception Class in net.engio.mbassy.bus.error
-
The universal exception type for message bus implementations.
- MessageBusException(String) - Constructor for exception class net.engio.mbassy.bus.error.MessageBusException
- MessageBusException(String, Throwable) - Constructor for exception class net.engio.mbassy.bus.error.MessageBusException
- MessageBusException(Throwable) - Constructor for exception class net.engio.mbassy.bus.error.MessageBusException
- MessageDispatcher - Class in net.engio.mbassy.dispatch
-
Standard implementation for direct, unfiltered message delivery.
- MessageDispatcher(SubscriptionContext, IHandlerInvocation) - Constructor for class net.engio.mbassy.dispatch.MessageDispatcher
- MessageDispatchThreadFactory - Static variable in class net.engio.mbassy.bus.config.Feature.AsynchronousMessageDispatch
- MessageEnvelope - Class in net.engio.mbassy.subscription
-
A message envelope is used to wrap messages of arbitrary type such that a handler my receive messages of different types.
- MessageEnvelope(Object) - Constructor for class net.engio.mbassy.subscription.MessageEnvelope
- MessageHandler - Class in net.engio.mbassy.listener
-
Any method in any class annotated with the @Handler annotation represents a message handler.
- MessageHandler(Map<String, Object>) - Constructor for class net.engio.mbassy.listener.MessageHandler
- MessageHandler.Properties - Class in net.engio.mbassy.listener
- MessageHandlerThreadFactory - Static variable in class net.engio.mbassy.bus.config.Feature.AsynchronousHandlerInvocation
- MessageListener<T> - Class in net.engio.mbassy.listener
-
All instances of any class defining at least one message handler @link MessageHandler are message listeners.
- MessageListener(Class<T>) - Constructor for class net.engio.mbassy.listener.MessageListener
- MessagePublication - Class in net.engio.mbassy.bus
-
A message publication is created for each asynchronous message dispatch.
- MessagePublication(BusRuntime, Collection<Subscription>, Object, MessagePublication.State) - Constructor for class net.engio.mbassy.bus.MessagePublication
- MessagePublication.Factory - Class in net.engio.mbassy.bus
- MessagePublication.State - Enum Class in net.engio.mbassy.bus
- messageQueue - Variable in class net.engio.mbassy.bus.config.Feature.AsynchronousMessageDispatch
- messages() - Element in annotation interface net.engio.mbassy.listener.Enveloped
-
The set of messages that should be dispatched to the message handler
- metadataReader - Variable in class net.engio.mbassy.bus.config.Feature.SyncPubSub
- metadataReader - Variable in class net.engio.mbassy.subscription.SubscriptionManager
- MetadataReader - Class in net.engio.mbassy.listener
-
The meta data reader is responsible for parsing and validating message handler configurations.
- MetadataReader() - Constructor for class net.engio.mbassy.listener.MetadataReader
- MissingFeature(Class<? extends Feature>) - Static method in exception class net.engio.mbassy.bus.config.ConfigurationError
- MissingPropertyException - Exception Class in net.engio.mbassy.bus.error
-
This exception is thrown when a property value that is unavailable at runtime is accessed.
- MissingPropertyException(String) - Constructor for exception class net.engio.mbassy.bus.error.MissingPropertyException
- msg - Static variable in class net.engio.mbassy.dispatch.el.StandardELResolutionContext.MsgMapper
- msgExpression - Variable in class net.engio.mbassy.dispatch.el.StandardELResolutionContext.MsgMapper
- MsgMapper() - Constructor for class net.engio.mbassy.dispatch.el.StandardELResolutionContext.MsgMapper
N
- net.engio.mbassy.bus - package net.engio.mbassy.bus
- net.engio.mbassy.bus.common - package net.engio.mbassy.bus.common
- net.engio.mbassy.bus.config - package net.engio.mbassy.bus.config
- net.engio.mbassy.bus.error - package net.engio.mbassy.bus.error
- net.engio.mbassy.bus.publication - package net.engio.mbassy.bus.publication
- net.engio.mbassy.common - package net.engio.mbassy.common
- net.engio.mbassy.dispatch - package net.engio.mbassy.dispatch
- net.engio.mbassy.dispatch.el - package net.engio.mbassy.dispatch.el
- net.engio.mbassy.listener - package net.engio.mbassy.listener
- net.engio.mbassy.subscription - package net.engio.mbassy.subscription
- next - Variable in class net.engio.mbassy.common.AbstractConcurrentSet.Entry
- next() - Method in class net.engio.mbassy.common.AbstractConcurrentSet.Entry
- next() - Method in interface net.engio.mbassy.common.ISetEntry
- nonListeners - Variable in class net.engio.mbassy.subscription.SubscriptionManager
- NoopFunctionMapper() - Constructor for class net.engio.mbassy.dispatch.el.StandardELResolutionContext.NoopFunctionMapper
- now() - Method in interface net.engio.mbassy.bus.publication.IPublicationCommand
-
Execute the message publication immediately.
- now() - Method in class net.engio.mbassy.bus.publication.SyncAsyncPostCommand
- now() - Method in class net.engio.mbassy.bus.SyncMessageBus.SyncPostCommand
- numberOfMessageDispatchers - Variable in class net.engio.mbassy.bus.config.Feature.AsynchronousMessageDispatch
O
- onSubscription - Variable in class net.engio.mbassy.subscription.Subscription
- onSubscription(Runnable) - Method in class net.engio.mbassy.subscription.Subscription.Handle
-
Add a runnable that is invoked after a new listener is subscribed to the corresponding subscription.
P
- passesFilter(Object) - Method in class net.engio.mbassy.dispatch.FilteredMessageDispatcher
- pendingMessages - Variable in class net.engio.mbassy.bus.AbstractSyncAsyncMessageBus
- post(T) - Method in interface net.engio.mbassy.bus.common.GenericMessagePublicationSupport
-
Publish a message to the bus using on of its supported message publication mechanisms.
- post(T) - Method in interface net.engio.mbassy.bus.common.IMessageBus
-
Publish a message to the bus using on of its supported message publication mechanisms.
- post(T) - Method in class net.engio.mbassy.bus.MBassador
- post(T) - Method in class net.engio.mbassy.bus.SyncMessageBus
- predecessor - Variable in class net.engio.mbassy.common.AbstractConcurrentSet.Entry
- printStackTrace - Variable in class net.engio.mbassy.bus.error.IPublicationErrorHandler.ConsoleLogger
- priority - Variable in class net.engio.mbassy.listener.MessageHandler
- priority() - Element in annotation interface net.engio.mbassy.listener.Handler
-
Handlers are ordered by priority and handlers with higher priority are processed before those with lower priority, i.e.
- Priority - Static variable in class net.engio.mbassy.listener.MessageHandler.Properties
- properties - Variable in class net.engio.mbassy.bus.BusRuntime
- properties - Variable in class net.engio.mbassy.bus.config.BusConfiguration
- Properties() - Constructor for class net.engio.mbassy.bus.config.IBusConfiguration.Properties
- Properties() - Constructor for class net.engio.mbassy.listener.MessageHandler.Properties
- provider - Variable in class net.engio.mbassy.bus.BusRuntime
- publication - Variable in class net.engio.mbassy.bus.error.PublicationError
- PublicationError - Class in net.engio.mbassy.bus.error
-
Publication errors are used to communicate exceptions that occur during message publication.
- PublicationError() - Constructor for class net.engio.mbassy.bus.error.PublicationError
-
Default constructor.
- PublicationError(Throwable, String) - Constructor for class net.engio.mbassy.bus.error.PublicationError
- PublicationError(Throwable, String, Method, Object, IMessagePublication) - Constructor for class net.engio.mbassy.bus.error.PublicationError
-
Compound constructor, creating a PublicationError from the supplied objects.
- PublicationError(Throwable, String, IMessagePublication) - Constructor for class net.engio.mbassy.bus.error.PublicationError
- PublicationError(Throwable, String, SubscriptionContext) - Constructor for class net.engio.mbassy.bus.error.PublicationError
- publicationErrorHandlers - Variable in class net.engio.mbassy.bus.config.BusConfiguration
- PublicationErrorHandlers - Static variable in class net.engio.mbassy.bus.config.IBusConfiguration.Properties
- PublicationEvent - Class in net.engio.mbassy.bus.common
-
A wrapped event is created when various conditions are matched (these depend on the concrete (sub)type of wrapped event).
- PublicationEvent(Object) - Constructor for class net.engio.mbassy.bus.common.PublicationEvent
- publicationFactory - Variable in class net.engio.mbassy.bus.AbstractPubSubSupport
- publicationFactory - Variable in class net.engio.mbassy.bus.config.Feature.SyncPubSub
- publish(MessagePublication, Object) - Method in class net.engio.mbassy.subscription.Subscription
- publish(T) - Method in interface net.engio.mbassy.bus.common.PubSubSupport
-
Synchronously publish a message to all registered listeners.
- publish(T) - Method in class net.engio.mbassy.bus.MBassador
-
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.
- publish(T) - Method in class net.engio.mbassy.bus.SyncMessageBus
- publishAsync(T) - Method in class net.engio.mbassy.bus.MBassador
- publishAsync(T, long, TimeUnit) - Method in class net.engio.mbassy.bus.MBassador
- PubSubSupport<T> - Interface in net.engio.mbassy.bus.common
-
This interface defines the very basic message publication semantics according to the publish subscribe pattern.
R
- readWriteLock - Variable in class net.engio.mbassy.subscription.SubscriptionManager
- references() - Element in annotation interface net.engio.mbassy.listener.Listener
-
BY DEFAULT, MBassador uses
WeakReference
. - References - Enum Class in net.engio.mbassy.listener
- References() - Constructor for enum class net.engio.mbassy.listener.References
- ReflectionUtils - Class in net.engio.mbassy.common
- ReflectionUtils() - Constructor for class net.engio.mbassy.common.ReflectionUtils
- ReflectiveHandlerInvocation - Class in net.engio.mbassy.dispatch
-
Uses reflection to invoke a message handler for a given message.
- ReflectiveHandlerInvocation(SubscriptionContext) - Constructor for class net.engio.mbassy.dispatch.ReflectiveHandlerInvocation
- rejectSubtypes() - Element in annotation interface net.engio.mbassy.listener.Handler
-
Define whether or not the handler accepts sub types of the message type it declares in its signature.
- RejectSubtypes() - Constructor for class net.engio.mbassy.listener.Filters.RejectSubtypes
- relatedMessage - Variable in class net.engio.mbassy.bus.common.PublicationEvent
- remove() - Method in class net.engio.mbassy.common.AbstractConcurrentSet.Entry
- remove() - Method in interface net.engio.mbassy.common.ISetEntry
- remove(Object) - Method in class net.engio.mbassy.common.AbstractConcurrentSet
- removeAll(Collection<?>) - Method in class net.engio.mbassy.common.AbstractConcurrentSet
- resolveFunction(String, String) - Method in class net.engio.mbassy.dispatch.el.StandardELResolutionContext.NoopFunctionMapper
- resolver - Variable in class net.engio.mbassy.dispatch.el.StandardELResolutionContext
- resolveVariable(String) - Method in class net.engio.mbassy.dispatch.el.StandardELResolutionContext.MsgMapper
- retainAll(Collection<?>) - Method in class net.engio.mbassy.common.AbstractConcurrentSet
- Running - Enum constant in enum class net.engio.mbassy.bus.MessagePublication.State
- runtime - Variable in class net.engio.mbassy.bus.AbstractPubSubSupport
- runtime - Variable in class net.engio.mbassy.bus.MessagePublication
- runtime - Variable in class net.engio.mbassy.subscription.SubscriptionContext
- runtime - Variable in class net.engio.mbassy.subscription.SubscriptionManager
- RuntimeProvider - Interface in net.engio.mbassy.bus.common
-
Each message bus provides a runtime object to access its dynamic features and runtime configuration.
S
- Scheduled - Enum constant in enum class net.engio.mbassy.bus.MessagePublication.State
- 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
- setProperty(String, Object) - Method in interface net.engio.mbassy.bus.config.IBusConfiguration
-
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
- setVariable(String, ValueExpression) - Method in class net.engio.mbassy.dispatch.el.StandardELResolutionContext.MsgMapper
- 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
- StandardELResolutionContext.MsgMapper - Class in net.engio.mbassy.dispatch.el
-
This mapper resolves the variable identifies "msg" to the message object of the current handler invocation
- StandardELResolutionContext.NoopFunctionMapper - Class in net.engio.mbassy.dispatch.el
-
This function mapper does nothing, i.e.
- state - Variable in class net.engio.mbassy.bus.MessagePublication
- State() - Constructor for enum class net.engio.mbassy.bus.MessagePublication.State
- Strong - Enum constant in enum class net.engio.mbassy.listener.References
- 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
- StrongEntry(T) - Constructor for class net.engio.mbassy.common.StrongConcurrentSet.StrongEntry
- StrongEntry(T, AbstractConcurrentSet.Entry<T>) - Constructor for class net.engio.mbassy.common.StrongConcurrentSet.StrongEntry
- 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
- subscribe(Object, Subscription[]) - 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(SubscriptionContext, IMessageDispatcher, Collection<Object>) - Constructor for class net.engio.mbassy.subscription.Subscription
- 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 - Variable in class net.engio.mbassy.bus.config.Feature.SyncPubSub
- subscriptionFactory - Variable in class net.engio.mbassy.subscription.SubscriptionManager
- 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 - Variable in class net.engio.mbassy.bus.AbstractPubSubSupport
- 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 - Variable in class net.engio.mbassy.bus.config.Feature.SyncPubSub
- SubscriptionManagerProvider - Class in net.engio.mbassy.subscription
- SubscriptionManagerProvider() - Constructor for class net.engio.mbassy.subscription.SubscriptionManagerProvider
- subscriptions - Variable in class net.engio.mbassy.bus.MessagePublication
- subscriptionsPerListener - Variable in class net.engio.mbassy.subscription.SubscriptionManager
- subscriptionsPerMessage - Variable in class net.engio.mbassy.subscription.SubscriptionManager
- 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 Interface 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
- Synchronously - Enum constant in enum class net.engio.mbassy.listener.Invoke
- 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(IBusConfiguration) - Constructor for class net.engio.mbassy.bus.SyncMessageBus
-
Construct with fully specified configuration
- SyncMessageBus(IPublicationErrorHandler) - Constructor for class net.engio.mbassy.bus.SyncMessageBus
-
Construct with default settings and specified publication error handler
- 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
T
- toArray() - Method in class net.engio.mbassy.common.AbstractConcurrentSet
- toArray(T[]) - Method in class net.engio.mbassy.common.AbstractConcurrentSet
- toString() - Method in class net.engio.mbassy.bus.AbstractPubSubSupport
- toString() - Method in exception class net.engio.mbassy.bus.config.ConfigurationError
- toString() - Method in class net.engio.mbassy.bus.error.PublicationError
U
- unsubscribe(Object) - Method in class net.engio.mbassy.bus.AbstractPubSubSupport
- unsubscribe(Object) - Method in interface net.engio.mbassy.bus.common.PubSubSupport
-
Immediately remove all registered message handlers (if any) of the given listener.
- unsubscribe(Object) - Method in class net.engio.mbassy.subscription.Subscription
- unsubscribe(Object) - Method in class net.engio.mbassy.subscription.SubscriptionManager
- useStrongReferences() - Method in class net.engio.mbassy.listener.MessageHandler
- useStrongReferences() - Method in class net.engio.mbassy.listener.MessageListener
V
- validate(Map<String, Object>) - Method in class net.engio.mbassy.listener.MessageHandler
- value - Variable in class net.engio.mbassy.common.StrongConcurrentSet.StrongEntry
- value - Variable in class net.engio.mbassy.common.WeakConcurrentSet.WeakEntry
- value() - Element in annotation interface net.engio.mbassy.listener.Filter
-
The class that implements the filter.
- value() - Element in annotation interface net.engio.mbassy.listener.IncludeFilters
-
An array of filters to be used for filtering
Handler
s. - valueOf(String) - Static method in enum class net.engio.mbassy.bus.MessagePublication.State
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class net.engio.mbassy.listener.Invoke
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class net.engio.mbassy.listener.References
-
Returns the enum constant of this class with the specified name.
- values() - Static method in enum class net.engio.mbassy.bus.MessagePublication.State
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class net.engio.mbassy.listener.Invoke
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class net.engio.mbassy.listener.References
-
Returns an array containing the constants of this enum class, in the order they are declared.
- variableMapper - Variable in class net.engio.mbassy.dispatch.el.StandardELResolutionContext
W
- Weak - Enum constant in enum class net.engio.mbassy.listener.References
- WeakConcurrentSet<T> - Class in net.engio.mbassy.common
-
This implementation uses weak references to the elements.
- WeakConcurrentSet() - Constructor for class net.engio.mbassy.common.WeakConcurrentSet
- WeakConcurrentSet.WeakEntry<T> - Class in net.engio.mbassy.common
- WeakEntry(T) - Constructor for class net.engio.mbassy.common.WeakConcurrentSet.WeakEntry
- WeakEntry(T, AbstractConcurrentSet.Entry<T>) - Constructor for class net.engio.mbassy.common.WeakConcurrentSet.WeakEntry
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form