Skip navigation links
mbassador, 1.3.3-SNAPSHOT
A B C D E F G H I L M N P R S T U V W 

A

AbstractConcurrentSet<T> - Class in net.engio.mbassy.common
This data structure is optimized for non-blocking reads even when write operations occur.
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(BusConfiguration) - 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 extends ISyncAsyncPublicationCommand> - Class in net.engio.mbassy.bus
The base class for all message bus implementations with support for asynchronous message dispatch
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() - 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
 
addFeature(Feature) - Method in class net.engio.mbassy.bus.config.BusConfiguration
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
Add a handler that will be called whenever a publication error occurs.
apply(T) - Method in interface net.engio.mbassy.common.IPredicate
 
Asynchronous - Annotation Type in net.engio.mbassy.listener
Mark an event handler as asynchronous.
AsynchronousHandlerExecutor - Static variable in class net.engio.mbassy.bus.config.BusConfiguration.Properties
 
AsynchronousHandlerInvocation() - Constructor for class net.engio.mbassy.bus.config.Feature.AsynchronousHandlerInvocation
 
AsynchronousHandlerInvocation - Class in net.engio.mbassy.dispatch
This invocation will schedule the wrapped (decorated) invocation to be executed asynchronously
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(long, TimeUnit) - 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 class net.engio.mbassy.bus.publication.SyncAsyncPostCommand
 
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.
BusConfiguration - Class in net.engio.mbassy.bus.config
The configuration of message bus instances is feature driven, e.g.
BusConfiguration() - Constructor for class net.engio.mbassy.bus.config.BusConfiguration
 
BusConfiguration.Properties - Class in net.engio.mbassy.bus.config
A collection of properties commonly used by different parts of the library.
BusId - Static variable in class net.engio.mbassy.bus.config.BusConfiguration.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

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
 
collectInterfaces(Class, Collection<Class>) - Static method in class net.engio.mbassy.common.ReflectionUtils
 
Condition - Static variable in class net.engio.mbassy.listener.MessageHandler.Properties
 
ConfigurationError - Exception in net.engio.mbassy.bus.config
Configuration errors represent specific invalid configurations of a feature in a BusConfiguration An invalid feature configuration is assumed to render the bus dysfunctional and as such is thrown as an unchecked exception.
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(String) - Method in class net.engio.mbassy.bus.BusRuntime
 
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.
containsAll(Collection<?>) - Method in class net.engio.mbassy.common.AbstractConcurrentSet
 
containsOverridingMethod(Method[], Method) - Static method in class net.engio.mbassy.common.ReflectionUtils
 
Create(Method, Handler, Enveloped, IMessageFilter[], MessageListener) - Static method in class net.engio.mbassy.listener.MessageHandler.Properties
Create the property map for the MessageHandler constructor using the default objects.
createManager(MetadataReader, SubscriptionFactory, BusRuntime) - Method in interface net.engio.mbassy.subscription.ISubscriptionManagerProvider
 
createManager(MetadataReader, SubscriptionFactory, BusRuntime) - Method in class net.engio.mbassy.subscription.SubscriptionManagerProvider
 
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(int, int) - 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
 
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
 
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
 

E

ELFactory() - Static method in class net.engio.mbassy.dispatch.el.ElFilter
 
ELFactory - Static variable in class net.engio.mbassy.dispatch.el.ElFilter.ExpressionFactoryHolder
 
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
 
Envelope - Class in net.engio.mbassy.subscription
A generic wrapper around events of unrelated type.
Envelope(Object) - Constructor for class net.engio.mbassy.subscription.Envelope
 
Enveloped - Annotation Type 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_HANDLER_MSG - Static variable in class net.engio.mbassy.bus.AbstractPubSubSupport
 
ErrorHandlingSupport - Interface in net.engio.mbassy.bus.common
Publication errors may occur at various points of time during message delivery.
execute() - Method in interface net.engio.mbassy.bus.IMessagePublication
 
execute() - Method in class net.engio.mbassy.bus.MessagePublication
 
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 - Annotation Type 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
 
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 - 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.
ForMessage(Class<?>) - Static method in class net.engio.mbassy.listener.MessageListener
 

G

GenericMessagePublicationSupport<T,P extends IPublicationCommand> - 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(AnnotatedElement, Class<A>) - Static method in class net.engio.mbassy.common.ReflectionUtils
 
getAnnotation(Class<A>) - Method in class net.engio.mbassy.listener.MessageHandler
 
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
getDispatcherThreadFactory() - Method in class net.engio.mbassy.bus.config.Feature.AsynchronousMessageDispatch
 
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.
getEvent() - Method in class net.engio.mbassy.subscription.Envelope
 
getExecutor() - Method in class net.engio.mbassy.bus.config.Feature.AsynchronousHandlerInvocation
 
getFeature(Class<T>) - Method in class net.engio.mbassy.bus.config.BusConfiguration
Get a registered feature by its type (class).
getFilter() - Method in class net.engio.mbassy.listener.MessageHandler
 
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
 
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
Read a property from this configuration.
getProvider() - Method in class net.engio.mbassy.bus.BusRuntime
 
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
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
 
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 BusConfiguration
Handle() - Constructor for class net.engio.mbassy.subscription.Subscription.Handle
 
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
 
Handler - Annotation Type in net.engio.mbassy.listener
Mark a method as event handler.
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
 
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
Check whether a property has been set.

I

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
The include filters directive can be used to add multiple Filters to a single annotation type.
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
 

L

Listener - Annotation Type 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
 

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<T> - Class in net.engio.mbassy.bus
 
MBassador() - Constructor for class net.engio.mbassy.bus.MBassador
Default constructor using default setup.
MBassador(IPublicationErrorHandler) - Constructor for class net.engio.mbassy.bus.MBassador
Construct with default settings and specified publication error handler
MBassador(BusConfiguration) - Constructor for class net.engio.mbassy.bus.MBassador
Construct with fully specified configuration
MessageBusException - Exception in net.engio.mbassy.bus.error
The universal exception type for message bus implementations.
MessageBusException(String) - Constructor for exception net.engio.mbassy.bus.error.MessageBusException
 
MessageBusException(String, Throwable) - Constructor for exception net.engio.mbassy.bus.error.MessageBusException
 
MessageBusException(Throwable) - Constructor for exception 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
 
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
 
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.Factory - Class in net.engio.mbassy.bus
 
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 net.engio.mbassy.bus.config.ConfigurationError
 
MissingPropertyException - Exception 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 net.engio.mbassy.bus.error.MissingPropertyException
 

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() - Method in class net.engio.mbassy.common.AbstractConcurrentSet.Entry
 
next() - Method in interface net.engio.mbassy.common.ISetEntry
 
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
 

P

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
 
Priority - Static variable in class net.engio.mbassy.listener.MessageHandler.Properties
 
Properties() - Constructor for class net.engio.mbassy.bus.config.BusConfiguration.Properties
 
Properties() - Constructor for class net.engio.mbassy.listener.MessageHandler.Properties
 
PublicationError - Class in net.engio.mbassy.bus.error
Publication errors are used to communicate exceptions that occur during message publication.
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
 
PublicationError(Throwable, String) - Constructor for class net.engio.mbassy.bus.error.PublicationError
 
PublicationError() - Constructor for class net.engio.mbassy.bus.error.PublicationError
Default constructor.
PublicationErrorHandlers - Static variable in class net.engio.mbassy.bus.config.BusConfiguration.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
 
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
 
publish(MessagePublication, Object) - Method in class net.engio.mbassy.subscription.Subscription
 
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

References - Enum in net.engio.mbassy.listener
 
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() - Constructor for class net.engio.mbassy.listener.Filters.RejectSubtypes
 
remove() - Method in class net.engio.mbassy.common.AbstractConcurrentSet.Entry
 
remove(Object) - Method in class net.engio.mbassy.common.AbstractConcurrentSet
 
remove() - Method in interface net.engio.mbassy.common.ISetEntry
 
removeAll(Collection<?>) - Method in class net.engio.mbassy.common.AbstractConcurrentSet
 
retainAll(Collection<?>) - Method in class net.engio.mbassy.common.AbstractConcurrentSet
 
RuntimeProvider - Interface in net.engio.mbassy.bus.common
Each message bus provides a runtime object to access its dynamic features and runtime configuration.

S

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
 

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 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

valueOf(String) - Static method in enum net.engio.mbassy.listener.Invoke
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum net.engio.mbassy.listener.References
Returns the enum constant of this type with the specified name.
values() - Static method in enum net.engio.mbassy.listener.Invoke
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum net.engio.mbassy.listener.References
Returns an array containing the constants of this enum type, in the order they are declared.

W

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
 
A B C D E F G H I L M N P R S T U V W 
Skip navigation links
mbassador, 1.3.3-SNAPSHOT

Copyright © 2018. All rights reserved.