io.spine.server.event

Class AbstractEventReactor

java.lang.Object

io.spine.server.event.AbstractEventReactor

All Implemented Interfaces:

MessageDispatcher<EventClass,EventEnvelope>, MulticastDispatcher<EventClass,EventEnvelope>, EventDispatcher, EventReactor, EventReceiver, EventProducer

Direct Known Subclasses:

AbstractStatefulReactor

public abstract class AbstractEventReactor
extends java.lang.Object
implements EventReactor, EventDispatcher

An abstract base for all classes that may produce events in response to other events.

Events may be produced in response to both domestic and external events.

To use one, do the following:

1. Create an instance, specifying the event bus which receives emitted events.
2. Register.

See Also:

reactors

Constructor Summary

Constructors

Constructor and Description
AbstractEventReactor()

Method Summary

Modifier and Type	Method and Description
void	dispatch(EventEnvelope event) Dispatches the message contained in the passed envelope.
com.google.common.collect.ImmutableSet<EventClass>	domesticEventClasses() Obtains classes of domestic events processed by this dispatcher.
com.google.common.collect.ImmutableSet<EventClass>	externalEventClasses() Obtains classes of external events processed by this dispatcher.
boolean	isRegistered()
com.google.common.collect.ImmutableSet<EventClass>	messageClasses() Obtains a set of message classes that can be processed by this dispatcher.
com.google.common.collect.ImmutableSet<EventClass>	producedEvents() Obtains classes of the events produced by this object.
com.google.protobuf.Any	producerId() Obtains the name of this reactor, packed to Any.
void	registerWith(BoundedContext context)
io.spine.core.Version	version() Returns a zero version.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.spine.server.EventProducer

nothing

Methods inherited from interface io.spine.server.event.EventDispatcher

dispatchesEvents, dispatchesExternalEvents, eventClasses

Methods inherited from interface io.spine.server.bus.MessageDispatcher

canDispatch

Constructor Detail

AbstractEventReactor

public AbstractEventReactor()

Method Detail

registerWith

public void registerWith(BoundedContext context)

isRegistered

public boolean isRegistered()

messageClasses

public com.google.common.collect.ImmutableSet<EventClass> messageClasses()

Description copied from interface: MessageDispatcher

Obtains a set of message classes that can be processed by this dispatcher.

Specified by:

messageClasses in interface MessageDispatcher<EventClass,EventEnvelope>

Returns:

non-empty set of message classes

dispatch

public void dispatch(EventEnvelope event)

Description copied from interface: MessageDispatcher

Dispatches the message contained in the passed envelope.

Specified by:

dispatch in interface MessageDispatcher<EventClass,EventEnvelope>

Parameters:

event - the envelope with the message

producerId

public com.google.protobuf.Any producerId()

Obtains the name of this reactor, packed to Any.

Specified by:

producerId in interface EventProducer

version

public io.spine.core.Version version()

Returns a zero version.

Specified by:

version in interface EventProducer

externalEventClasses

public com.google.common.collect.ImmutableSet<EventClass> externalEventClasses()

Description copied from interface: EventDispatcher

Obtains classes of external events processed by this dispatcher.

Specified by:

externalEventClasses in interface EventDispatcher

domesticEventClasses

public com.google.common.collect.ImmutableSet<EventClass> domesticEventClasses()

Description copied from interface: EventDispatcher

Obtains classes of domestic events processed by this dispatcher.

Specified by:

domesticEventClasses in interface EventDispatcher

producedEvents

public com.google.common.collect.ImmutableSet<EventClass> producedEvents()

Description copied from interface: EventProducer

Obtains classes of the events produced by this object.

Specified by:

producedEvents in interface EventProducer