rabbitmq

May 5, 2020

Changes in this version

+ type Config struct

+ Host string

+ Port int64

+ func StartRabbitmqContainer(options ContainerOptions) (rabbitmqC testcontainers.Container, rabbitmqConfig Config, err error)

+ type ContainerOptions struct

Apr 28, 2020

Changes in this version

+ func Publish(message string, options Options, ch *amqp.Channel, count int)

+ func Setup(options Options) (*amqp.Connection, *amqp.Channel)

+ func SetupConsumer(options ConsumerOptions, ch *amqp.Channel) *amqp.Channel

+ type ConsumerOptions struct

+ ExchangeName string

+ ExchangeRoutingKey string

+ QueueLength int64

+ QueueName string

+ type Options struct

+ ExchangeName string

+ ExchangeRoutingKey string

+ Host string

+ Port int64

+ func (options Options) ConnectionURI() string