Package-level declarations
Types
Link copied to clipboard
open class TransportCommandBus(transport: Transport, topicNaming: TopicNaming, decodeFailureHandler: TransportDecodeFailureHandler = TransportDecodeFailureHandler.FAIL) : TransportMessageBus<CommandMessage<*>, ServerCommandExchange<*>> , DistributedCommandBus
The distributed command bus over a Transport.
Link copied to clipboard
class TransportServerCommandExchange<C : Any>(val message: CommandMessage<C>, val record: TransportRecord, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : ServerCommandExchange<C>