Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsumerOptions ¶
type ConsumerOptions struct { ExchangeName string QueueName string ExchangeRoutingKey string QueueLength int64 }
ConsumerOptions ...
func (*ConsumerOptions) SetupQueue ¶
func (options *ConsumerOptions) SetupQueue(ch *amqp.Channel) error
SetupQueue ...
type Container ¶
type Container struct { Container testcontainers.Container tc.ContainerConfig Host string Port int64 }
Container ...
type ProducerOptions ¶
type ProducerOptions struct { Host string Port int64 ExchangeName string ExchangeRoutingKey string }
ProducerOptions for rabbitmq
func (*ProducerOptions) ConnectionURI ¶
func (options *ProducerOptions) ConnectionURI() string
ConnectionURI ...
func (*ProducerOptions) SetupConnection ¶
func (options *ProducerOptions) SetupConnection() (*amqp.Connection, *amqp.Channel, error)
SetupConnection ...
Click to show internal directories.
Click to hide internal directories.