Index

A C D F I L M N P R S U V 
All Classes and Interfaces|All Packages|Constant Field Values

A

ACCEPT - Enum constant in enum class it.tidalwave.messagebus.spi.ReflectionUtils.MethodProcessor.FilterResult
The methods of the class must be processed.
add(Class<T>, T) - Method in class it.tidalwave.messagebus.spi.MultiQueue
Adds a message of the given topic to this queue and issues a notification.

C

containsAnnotation(Annotation[], Class<?>) - Static method in class it.tidalwave.messagebus.spi.ReflectionUtils
Checks whether an array of annotations contains an annotation of the given type.
createMethodAdapter(Object, Method, Class<T>) - Method in interface it.tidalwave.messagebus.MessageBusHelper.Adapter
Creates a MessageBusHelper.MethodAdapter that delivers the messages of the given topic to the given method of the given object.

D

DEFAULT_SOURCE - Static variable in annotation interface it.tidalwave.messagebus.annotation.SimpleMessageSubscriber
The name of the default source.
deliverMessage(Class<T>, T) - Method in interface it.tidalwave.messagebus.spi.MessageDelivery
Delivers a message to the listeners.
deliverMessage(Class<T>, T) - Method in class it.tidalwave.messagebus.spi.RoundRobinAsyncMessageDelivery
Delivers a message to the listeners.
deliverMessage(Class<T>, T) - Method in class it.tidalwave.messagebus.spi.SimpleAsyncMessageDelivery
Delivers a message to the listeners.
dispatchMessage(Class<T>, T) - Method in class it.tidalwave.messagebus.spi.SimpleMessageBus
Dispatches a message to all the listeners subscribed to its topic, or to a supertype of it.

F

filter(Class<?>) - Method in interface it.tidalwave.messagebus.spi.ReflectionUtils.MethodProcessor
Decides whether the methods declared in the given class must be processed.
forEachMethodInBottomUpHierarchy(Object, ReflectionUtils.MethodProcessor) - Static method in class it.tidalwave.messagebus.spi.ReflectionUtils
Navigates the hierarchy of the given object, bottom up (that is, starting from the class of the object), and applies the ReflectionUtils.MethodProcessor to all the methods of each class, if not filtered out by the processor itself.
forEachMethodInTopDownHierarchy(Object, ReflectionUtils.MethodProcessor) - Static method in class it.tidalwave.messagebus.spi.ReflectionUtils
Navigates the hierarchy of the given object, top down (that is, starting from Object), and applies the ReflectionUtils.MethodProcessor to all the methods of each class, if not filtered out by the processor itself.

I

IGNORE - Enum constant in enum class it.tidalwave.messagebus.spi.ReflectionUtils.MethodProcessor.FilterResult
The methods of the class must be ignored.
initialize(SimpleMessageBus) - Method in interface it.tidalwave.messagebus.spi.MessageDelivery
Initializes this object.
initialize(SimpleMessageBus) - Method in class it.tidalwave.messagebus.spi.RoundRobinAsyncMessageDelivery
Initializes this object.
initialize(SimpleMessageBus) - Method in class it.tidalwave.messagebus.spi.SimpleAsyncMessageDelivery
Initializes this object.
it.tidalwave.messagebus - module it.tidalwave.messagebus
 
it.tidalwave.messagebus - package it.tidalwave.messagebus
 
it.tidalwave.messagebus.annotation - package it.tidalwave.messagebus.annotation
 
it.tidalwave.messagebus.spi - package it.tidalwave.messagebus.spi
 

L

ListensTo - Annotation Interface in it.tidalwave.messagebus.annotation
This annotation is used to write simpler code which uses a message bus.

M

MessageBus - Interface in it.tidalwave.messagebus
A simple message bus for a local publish/subscribe facility.
MessageBus.Listener<T> - Interface in it.tidalwave.messagebus
A listener to receive notifications from a MessageBus.
MessageBusHelper - Class in it.tidalwave.messagebus
A helper for objects that receive messages by means of listener methods: methods with a single parameter annotated with ListensTo.
MessageBusHelper() - Constructor for class it.tidalwave.messagebus.MessageBusHelper
 
MessageBusHelper.Adapter - Interface in it.tidalwave.messagebus
An adapter between MessageBusHelper and a specific message bus.
MessageBusHelper.MethodAdapter<T> - Interface in it.tidalwave.messagebus
The binding of a listener method to a message bus, which can subscribe and unsubscribe it.
MessageDelivery - Interface in it.tidalwave.messagebus.spi
A strategy for message delivery in the SimpleMessageBus.
MultiQueue - Class in it.tidalwave.messagebus.spi
A set of queues of messages, one for each topic.
MultiQueue() - Constructor for class it.tidalwave.messagebus.spi.MultiQueue
 

N

notify(T) - Method in interface it.tidalwave.messagebus.MessageBus.Listener
Notifies the reception of the given message.

P

process(Method) - Method in interface it.tidalwave.messagebus.spi.ReflectionUtils.MethodProcessor
Processes a method.
publish(Class<T>, T) - Method in interface it.tidalwave.messagebus.MessageBus
Publishes the given message and topic.
publish(Class<T>, T) - Method in interface it.tidalwave.messagebus.MessageBusHelper.Adapter
Publishes a message with an explicit topic.
publish(Class<T>, T) - Method in class it.tidalwave.messagebus.MessageBusHelper
Publishes a message with an explicit topic.
publish(Class<T>, T) - Method in class it.tidalwave.messagebus.spi.SimpleMessageBus
Publishes the given message and topic.
publish(Object) - Method in interface it.tidalwave.messagebus.MessageBusHelper.Adapter
Publishes a message.
publish(Object) - Method in class it.tidalwave.messagebus.MessageBusHelper
Publishes a message.
publish(T) - Method in interface it.tidalwave.messagebus.MessageBus
Publishes the given event.
publish(T) - Method in class it.tidalwave.messagebus.spi.SimpleMessageBus
Publishes the given event.

R

ReflectionUtils - Class in it.tidalwave.messagebus.spi
Utilities for navigating, by means of reflection, the methods declared in the classes of the hierarchy of an object.
ReflectionUtils() - Constructor for class it.tidalwave.messagebus.spi.ReflectionUtils
 
ReflectionUtils.MethodProcessor - Interface in it.tidalwave.messagebus.spi
A processor of the methods of a hierarchy of classes.
ReflectionUtils.MethodProcessor.FilterResult - Enum Class in it.tidalwave.messagebus.spi
The result of ReflectionUtils.MethodProcessor.filter(Class): ACCEPT if the methods of the class must be processed, IGNORE otherwise.
remove() - Method in class it.tidalwave.messagebus.spi.MultiQueue
Removes and returns the next pair (topic, message) from the queue.
RoundRobinAsyncMessageDelivery - Class in it.tidalwave.messagebus.spi
An implementation of MessageDelivery that keeps a queue of messages for each topic, and dispatches them in a round-robin fashion, topic by topic, so a topic with many messages doesn't starve the others (see MultiQueue).
RoundRobinAsyncMessageDelivery() - Constructor for class it.tidalwave.messagebus.spi.RoundRobinAsyncMessageDelivery
 

S

SimpleAsyncMessageDelivery - Class in it.tidalwave.messagebus.spi
An implementation of MessageDelivery that dispatches messages as soon as they are published, each one in a separate task of the Executor of the SimpleMessageBus.
SimpleAsyncMessageDelivery() - Constructor for class it.tidalwave.messagebus.spi.SimpleAsyncMessageDelivery
 
SimpleMessageBus - Class in it.tidalwave.messagebus.spi
An implementation of MessageBus.
SimpleMessageBus() - Constructor for class it.tidalwave.messagebus.spi.SimpleMessageBus
Creates a new instance with a SimpleAsyncMessageDelivery strategy for delivery.
SimpleMessageBus(Executor) - Constructor for class it.tidalwave.messagebus.spi.SimpleMessageBus
Creates a new instance given an executor and a SimpleAsyncMessageDelivery strategy for delivery.
SimpleMessageBus(Executor, MessageDelivery) - Constructor for class it.tidalwave.messagebus.spi.SimpleMessageBus
Creates a new instance given an executor and a strategy for delivery.
SimpleMessageSubscriber - Annotation Interface in it.tidalwave.messagebus.annotation
Designates a class as a simple subscriber of a message bus.
source() - Element in annotation interface it.tidalwave.messagebus.annotation.SimpleMessageSubscriber
The name of the source that this annotation refers to.
subscribe() - Method in interface it.tidalwave.messagebus.MessageBusHelper.MethodAdapter
Subscribes the listener method to the message bus.
subscribe(Class<T>, MessageBus.Listener<T>) - Method in interface it.tidalwave.messagebus.MessageBus
Subscribes a MessageBus.Listener to a topic.
subscribe(Class<T>, MessageBus.Listener<T>) - Method in class it.tidalwave.messagebus.spi.SimpleMessageBus
Subscribes a MessageBus.Listener to a topic.
subscribeAll() - Method in class it.tidalwave.messagebus.MessageBusHelper
Subscribes all the listener methods of the owner object: the methods with a single parameter annotated with ListensTo, declared in the classes of the hierarchy of the owner that are annotated with SimpleMessageSubscriber.

U

unsubscribe() - Method in interface it.tidalwave.messagebus.MessageBusHelper.MethodAdapter
Unsubscribes the listener method from the message bus.
unsubscribe(MessageBus.Listener<?>) - Method in interface it.tidalwave.messagebus.MessageBus
Unsubscribes a MessageBus.Listener from all the topics it was subscribed to.
unsubscribe(MessageBus.Listener<?>) - Method in class it.tidalwave.messagebus.spi.SimpleMessageBus
Unsubscribes a MessageBus.Listener from all the topics it was subscribed to.
unsubscribeAll() - Method in class it.tidalwave.messagebus.MessageBusHelper
Unsubscribes all the listener methods subscribed by MessageBusHelper.subscribeAll().

V

valueOf(String) - Static method in enum class it.tidalwave.messagebus.spi.ReflectionUtils.MethodProcessor.FilterResult
Returns the enum constant of this class with the specified name.
values() - Static method in enum class it.tidalwave.messagebus.spi.ReflectionUtils.MethodProcessor.FilterResult
Returns an array containing the constants of this enum class, in the order they are declared.
A C D F I L M N P R S U V 
All Classes and Interfaces|All Packages|Constant Field Values