GetFqn gets the "fully qualified name" of an interface.

GetTypeFQN gets the "fully qualified name" of a type.

NewBusMessage factory method for creating a BusMessage that wraps the given payload.

NewFromAMQPHeaders creates a BusMessage from headers of an amqp message.

MaxRetryCount defines the max times a retry can run.

AMQPOutbox sends messages to the amqp transport.

BusMessage the structure that gets sent to the underlying transport.

DefaultBus implements the Bus interface.

HealthCard that holds the health values of the bus.

Safety provides utility methods to safly invoke methods.

SagaTimeoutMessage is the timeout message for Saga's.

Builder is the main interface that should be used to create an instance of a Bus.

Bus interface provides the majority of functionality to Send, Reply and Publish messages to the Bus.

BusSwitch starts and shutdowns the bus.

HandlerRegister registers message handlers to specific messages and events.

Health reports om health issues in which the bus needs to be restarted.

Invocation context for a specific processed message.

Message a common interface that passes to the serializers to allow decoding and encoding of content.

MessagePolicy defines a user policy for out going amqp messages User policies can control message ttl, durability etc..

Messaging interface to send and publish messages to the bus.

RegisterDeadletterHandler provides the ability to handle messages that were rejected as poision and arrive to the deadletter queue.

RequestSagaTimeout is the interface a saga needs to implement to get timeout servicess.

Saga is the base interface for all Sagas.

SagaRegister registers sagas to the bus.

Serializer is the base interface for all message serializers.

TxOutbox abstracts the transactional outgoing channel type.

TxProvider provides a new Tx from the configured driver to the bus.

MessageHandler signature for all command handlers.

SagaConfFn is a function to allow configuration of a saga in the context of the gbus.