server/io.spine.server.bus

Package-level declarations

This package contains classes and interfaces for abstract Bus.

Types

public final class Acks

A utility for producing Ack instances.

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.

public abstract class BusBuilder<B extends BusBuilder<B, T, E, C, D>, T extends Signal<?, ?, ?>, E extends SignalEnvelope<? extends Object, T, ? extends Object>, C extends MessageClass<? extends Message>, D extends MessageDispatcher<C, E>>

The implementation base for the bus builders.

public interface BusFilter<E extends MessageEnvelope<? extends Object, ? extends Object, ? extends Object>> implements AutoCloseable

The filter for the messages posted to a bus.

public interface DeadMessageHandler<E extends MessageEnvelope<? extends Object, ? extends Object, ? extends Object>>

A definition of a handler for a dead message.

public abstract class DispatcherRegistry<C extends MessageClass<? extends Message>, E extends MessageEnvelope<? extends Object, ? extends Object, ? extends Object>, D extends MessageDispatcher<C, E>>

A registry of message dispatchers.

public interface EnvelopeValidator<E extends MessageEnvelope<? extends Object, ? extends Object, ? extends Object>>

An interface defining the validator for a MessageEnvelope.

public interface Listener<E extends MessageEnvelope<? extends Object, ? extends Object, ? extends Object>> implements Consumer<T>

A listener receives a message when it is posted to a Busbefore it is processed by filters.

public interface MessageDispatcher<C extends MessageClass, E extends MessageEnvelope>

A dispatcher of a message.

public interface MessageUnhandled implements MessageError

An interface for the MessageError types which report an unhandled message being posted into a Bus.

public abstract class MulticastBus<M extends Signal<?, ?, ?>, E extends SignalEnvelope<? extends Object, M, ? extends Object>, C extends MessageClass<? extends Message>, D extends MessageDispatcher<C, E>> extends Bus<T, E, C, D>

A Bus, which delivers a single message to multiple dispatchers.

public interface MulticastDispatcher<C extends MessageClass, E extends MessageEnvelope> implements MessageDispatcher<C, E>

Dispatches a message to several entities of the same type.

A listener of dispatching operations performed in MulticastBus.

public abstract class UnicastBus<T extends Signal<?, ?, ?>, E extends SignalEnvelope<? extends Object, T, ? extends Object>, C extends MessageClass<? extends Message>, D extends MessageDispatcher<C, E>> extends Bus<T, E, C, D>

A bus which delivers a message to one dispatcher.

public interface UnicastDispatcher<C extends MessageClass, E extends MessageEnvelope> implements MessageDispatcher<C, E>

Dispatches a message to one entity.