# Functions
No description provided by the author
GetFqn gets the "fully qualified name" of an interface.
GetMessageName extracts the valuee of the custom x-msg-name header from an amq delivery.
GetTypeFQN gets the "fully qualified name" of a type.
NewBusMessage factory method for creating a BusMessage that wraps the given payload.
NewFromDelivery creates a BusMessage from an amqp delivery.
NewMessageFilter creates a new MessageFilter.
NewRegistration creates a new registration.
# Variables
BaseRetryDuration defines the basic milliseconds that the retry algorithm usesfor a random retry time.
No description provided by the author
MaxRetryCount defines the max times a retry can run.Default is 3 but it is configurable.
No description provided by the author
RPCHeaderName used to define the header in grabbit for RPC.
# Structs
AMQPOutbox sends messages to the amqp transport.
BusConfiguration provides configuration passed to the bus builder.
BusMessage the structure that gets sent to the underlying transport.
DefaultBus implements the Bus interface.
DeliveryInfo provdes information as to the attempted deilvery of the invocation.
Glogged provides an easy way for structs with in the grabbit package to participate in the general logging schema of the bus.
HealthCard that holds the health values of the bus.
MessageFilter matches rabbitmq topic patterns.
OutboxConfiguration configures the transactional outbox.
Registration represents a message handler's registration for a given exchange, topic and msg combination.
Safety provides utility methods to safly invoke methods.
SagaTimeoutMessage is the timeout message for Saga's.
# Interfaces
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.
Deadlettering provides the ability to handle messages that were rejected as poision and arrive to the deadletter queue.
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.
Logged represents a grabbit component that can be logged.
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.
RawMessageHandling provides the ability to consume and send raq amqp messages with the transactional guarantees that the bus provides.
RequestSagaTimeout is the interface a saga needs to implement to get timeout servicess.
Saga is the base interface for all Sagas.
SagaGlue glues together all the parts needed in order to orchistrate saga instances.
SagaInvocation allows saga instances to reply to their creator even when not in the conext of handling
the message that starts the saga.
SagaRegister registers sagas to the bus.
Serializer is the base interface for all message serializers.
TimeoutManager abstracts the implementation of determining when a saga should be timed out.
TxOutbox abstracts the transactional outgoing channel type.
TxProvider provides a new Tx from the configured driver to the bus.
# Type aliases
MessageHandler signature for all command handlers.
RawMessageHandler signature for handlers that handle raw amqp deliveries.
SagaConfFn is a function to allow configuration of a saga in the context of the gbus.
Semantics reopresents the semantics of a grabbit message.