Module it.tidalwave.messagebus
Package it.tidalwave.messagebus.spi
package it.tidalwave.messagebus.spi
-
ClassDescriptionA strategy for message delivery in the
SimpleMessageBus.A set of queues of messages, one for each topic.Utilities for navigating, by means of reflection, the methods declared in the classes of the hierarchy of an object.A processor of the methods of a hierarchy of classes.The result ofReflectionUtils.MethodProcessor.filter(Class):ACCEPTif the methods of the class must be processed,IGNOREotherwise.An implementation ofMessageDeliverythat 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 (seeMultiQueue).An implementation ofMessageDeliverythat dispatches messages as soon as they are published, each one in a separate task of theExecutorof theSimpleMessageBus.An implementation ofMessageBus.