Inbox

public final class Inbox<I>

A container for the messages dispatched to a certain consumer, such as an event subscriber or a command handler.

Serves as a pre-stage allowing to filter, deduplicate and reorder messages before they are dispatched to their destination.

<I>

the type of consumer identifiers.

Types

public final class Builder<I>

A builder of Inbox instances.

The available destinations for the Commandss sent via this inbox.

public final class EventDestinations

The available destinations for the Events sent via this inbox.

public ShardedMessageDelivery<InboxMessage> delivery()

Returns an Inbox-specific mechanism of delivery the previously sharded messages to the endpoints configured for this Inbox instance.

public TypeUrl entityStateType()

Returns the state type of entities served by this Inbox.

Sends a command envelope to the Inbox and allows to set a destination for this message, determining its processing destiny.

Sends an event envelope to the Inbox and allows to set a destination for this message, determining its processing destiny.

public void unregister()

Unregisters this Inbox instance in the JVM-wide Delivery.