Bus
public abstract class Bus<T extends Signal<?, ?, ?>, E extends SignalEnvelope<? extends Object, T, ? extends Object>, C extends MessageClass<? extends Message>, D extends MessageDispatcher<C, E>> implements Closeable
Abstract base for buses.
Parameters
<T>
the type of outer objects (containing messages of interest) that are posted to the bus
<E>
the type of envelopes for outer objects used by this bus
<C>
the type of message class
<D>
the type of dispatches used by this bus
Inheritors
Constructors
Functions
Link copied to clipboard
Obtains the instance of DeadMessageHandler for this bus.
Link copied to clipboard
Link copied to clipboard
Called after the dispatching of the signal to all of the target dispatchers has been completed.
Link copied to clipboard
Called before the dispatching of the signal with the passed ID is started.
Link copied to clipboard
Prepares the given StreamObserver to post messages into this bus.
Link copied to clipboard
Link copied to clipboard
Packs the given message of type
T
into an envelope of type E
.Link copied to clipboard
Unregisters dispatching for message classes of the passed dispatcher.
Link copied to clipboard
Obtains the instance of EnvelopeValidator for this bus.