A C D F I L M N P R S U V
All Classes All Packages

A

ACCEPT - it.tidalwave.messagebus.spi.ReflectionUtils.MethodProcessor.FilterResult

add(Class<TOPIC>, TOPIC) - 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<TOPIC>) - Method in interface it.tidalwave.messagebus.MessageBusHelper.Adapter

D

DEFAULT_SOURCE - Static variable in annotation type it.tidalwave.messagebus.annotation.SimpleMessageSubscriber

deliverMessage(Class<TOPIC>, TOPIC) - Method in interface it.tidalwave.messagebus.spi.MessageDelivery

Delivers a message.

deliverMessage(Class<TOPIC>, TOPIC) - Method in class it.tidalwave.messagebus.spi.RoundRobinAsyncMessageDelivery

Delivers a message.

deliverMessage(Class<TOPIC>, TOPIC) - Method in class it.tidalwave.messagebus.spi.SimpleAsyncMessageDelivery

dispatchMessage(Class<TOPIC>, TOPIC) - Method in class it.tidalwave.messagebus.spi.SimpleMessageBus

Dispatches a message.

F

filter(Class<?>) - Method in interface it.tidalwave.messagebus.spi.ReflectionUtils.MethodProcessor

filter(Class<?>) - Method in class it.tidalwave.messagebus.spi.ReflectionUtils.MethodProcessorSupport

forEachMethodInBottomUpHierarchy(Object, ReflectionUtils.MethodProcessor) - Static method in class it.tidalwave.messagebus.spi.ReflectionUtils

Navigates the hierarchy of the given object, bottom up, 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, and applies the ReflectionUtils.MethodProcessor to all the methods of each class, if not filtered out by the processor itself.

I

IGNORE - it.tidalwave.messagebus.spi.ReflectionUtils.MethodProcessor.FilterResult

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

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 Type 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<TOPIC> - Interface in it.tidalwave.messagebus

A listener to receive notifications from a MessageBus.

MessageBusHelper - Class in it.tidalwave.messagebus

MessageBusHelper() - Constructor for class it.tidalwave.messagebus.MessageBusHelper

MessageBusHelper.Adapter - Interface in it.tidalwave.messagebus

MessageBusHelper.MethodAdapter<TOPIC> - Interface in it.tidalwave.messagebus

MessageDelivery - Interface in it.tidalwave.messagebus.spi

A strategy for message delivery in the SimpleMessageBus.

MethodProcessorSupport() - Constructor for class it.tidalwave.messagebus.spi.ReflectionUtils.MethodProcessorSupport

MultiQueue - Class in it.tidalwave.messagebus.spi

MultiQueue() - Constructor for class it.tidalwave.messagebus.spi.MultiQueue

N

notify(TOPIC) - 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

process(Method) - Method in class it.tidalwave.messagebus.spi.ReflectionUtils.MethodProcessorSupport

publish(Class<TOPIC>, TOPIC) - Method in interface it.tidalwave.messagebus.MessageBus

Publishes the given message and topic.

publish(Class<TOPIC>, TOPIC) - Method in interface it.tidalwave.messagebus.MessageBusHelper.Adapter

publish(Class<TOPIC>, TOPIC) - Method in class it.tidalwave.messagebus.MessageBusHelper

Publishes a message.

publish(Class<TOPIC>, TOPIC) - Method in class it.tidalwave.messagebus.spi.SimpleMessageBus

Publishes the given message and topic.

publish(Object) - Method in interface it.tidalwave.messagebus.MessageBusHelper.Adapter

publish(Object) - Method in class it.tidalwave.messagebus.MessageBusHelper

Publishes a message.

publish(TOPIC) - Method in interface it.tidalwave.messagebus.MessageBus

Publishes the given event.

publish(TOPIC) - Method in class it.tidalwave.messagebus.spi.SimpleMessageBus

Publishes the given event.

R

ReflectionUtils - Class in it.tidalwave.messagebus.spi

ReflectionUtils() - Constructor for class it.tidalwave.messagebus.spi.ReflectionUtils

ReflectionUtils.MethodProcessor - Interface in it.tidalwave.messagebus.spi

ReflectionUtils.MethodProcessor.FilterResult - Enum in it.tidalwave.messagebus.spi

ReflectionUtils.MethodProcessorSupport - Class in it.tidalwave.messagebus.spi

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 dispatches messages in a round-robin fashion, topic by topic.

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 they are delivered, each one in a separated thread.

SimpleAsyncMessageDelivery() - Constructor for class it.tidalwave.messagebus.spi.SimpleAsyncMessageDelivery

SimpleMessageBus - Class in it.tidalwave.messagebus.spi

A partial 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 Type in it.tidalwave.messagebus.annotation

Designates a class as a simple subscriber of a message bus.

source() - Method in annotation type it.tidalwave.messagebus.annotation.SimpleMessageSubscriber

The name of the source that this annotation refers to.

subscribe() - Method in interface it.tidalwave.messagebus.MessageBusHelper.MethodAdapter

subscribe(Class<TOPIC>, MessageBus.Listener<TOPIC>) - Method in interface it.tidalwave.messagebus.MessageBus

Subscribes a MessageBus.Listener to a topic.

subscribe(Class<TOPIC>, MessageBus.Listener<TOPIC>) - Method in class it.tidalwave.messagebus.spi.SimpleMessageBus

Subscribes a MessageBus.Listener to a topic.

subscribeAll() - Method in class it.tidalwave.messagebus.MessageBusHelper

U

unsubscribe() - Method in interface it.tidalwave.messagebus.MessageBusHelper.MethodAdapter

unsubscribe(MessageBus.Listener<?>) - Method in interface it.tidalwave.messagebus.MessageBus

Unsubscribes a MessageBus.Listener.

unsubscribe(MessageBus.Listener<?>) - Method in class it.tidalwave.messagebus.spi.SimpleMessageBus

Unsubscribes a MessageBus.Listener.

unsubscribeAll() - Method in class it.tidalwave.messagebus.MessageBusHelper

V

valueOf(String) - Static method in enum it.tidalwave.messagebus.spi.ReflectionUtils.MethodProcessor.FilterResult

Returns the enum constant of this type with the specified name.

values() - Static method in enum it.tidalwave.messagebus.spi.ReflectionUtils.MethodProcessor.FilterResult

Returns an array containing the constants of this enum type, in the order they are declared.

A C D F I L M N P R S U V
All Classes All Packages