Documentation
¶
Overview ¶
Package rabbitmq publishes outbox events to RabbitMQ with publisher confirms, persistent delivery and automatic reconnection.
Unroutable messages are confirmed by the broker and silently dropped; configure an alternate-exchange on your exchange if that matters for you.
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNack = errors.New("rabbitmq: message nacked by broker")
ErrNack is returned when the broker negatively acknowledges a message.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
URL string
// Exchange to publish to. Empty means the default exchange, where Event.Topic
// is the destination queue name. Otherwise Event.Topic is the routing key.
Exchange string
// DefaultRoutingKey is used when Event.Topic is empty.
DefaultRoutingKey string
// AMQP optionally customises the connection (TLS, heartbeat, ...).
AMQP *amqp.Config
}
Config configures the publisher.
Source Files
Click to show internal directories.
Click to hide internal directories.