Interface describing the component that remotely connects multiple CommandBus instances.
Interface describing a filter that can be applied to commands to describe the type of commands supported by a node in a cluster.
Interface describing a mechanism used to find a suitable member of a cluster capable of handling given command message.
Represents a listener that is notified when a ConsistentHash instance of the component it is registered with has changed.
Member of a cluster of connected command endpoints.
Interface describing a mechanism that generates a routing key for a given command.
Abstract implementation of the RoutingStrategy interface that uses a policy to prescribe what happens when a routing cannot be resolved.
RoutingStrategy that expects an
This class retains a list of callbacks for CommandCallbackConnectors to use.
Wrapper for a Command callback.
Component used by command routers to find members capable of handling a given command.
Member implementation used by a
Base class for dispatch messages which may be used in the
Implementation of a
Builder class to instantiate a
RoutingStrategy implementation that uses the value in the MetaData of a CommandMessage assigned to a given key.
Base class for reply messages which may be used in the
An endpoint in the network for a command handling service.
Exception thrown when the CommandBusConnector has a communication failure
Exception indicating that an error has occurred while trying to dispatch a command to another (potentially remote) segment of the CommandBus.
Exception that is triggered when an error occurs that is related to the registration or deregistration of a member to the distributed command bus service registry.
Copyright © 2010–2021. All rights reserved.