Versions in this module Expand all Collapse all v1 v1.3.0 May 13, 2024 v1.0.0 Apr 6, 2024 Changes in this version + func NewPubSub(tb watermilltest.TestingTB, conn *amqp.ConnectionWrapper, ...) (*amqp.Publisher, *amqp.Subscriber) + type RabbitMQ struct + func NewRabbitMQ(pool *dockertest.Pool, opts ...RabbitMQOption) (*RabbitMQ, error) + func (rmq *RabbitMQ) Close() error + func (rmq *RabbitMQ) NewConnection(tb watermilltest.TestingTB) *amqp.ConnectionWrapper + type RabbitMQOption func(cfg *rabbitMQConfig) + func WithRabbitMQImage(image string) RabbitMQOption + func WithRabbitMQTTL(ttlSeconds uint) RabbitMQOption + type TopicNameGenerator amqp.QueueNameGenerator