rabbitmq

package

v0.2.1 Latest Latest Go to latest Published: Feb 2, 2021 License: MIT Imports: 10 Imported by: 1

Details

This section is empty.

This section is empty.

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

Publish ...

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

Setup ...

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

SetupConsumer ...

type Config struct {
	tc.ContainerConfig
	Host string
	Port int64
}

Config ...

func StartRabbitmqContainer(ctx context.Context, options ContainerOptions) (rabbitmqC testcontainers.Container, rabbitmqConfig Config, err error)

StartRabbitmqContainer ...

type ConsumerOptions struct {
	ExchangeName       string
	QueueName          string
	ExchangeRoutingKey string
	QueueLength        int64
}

ConsumerOptions ...

type ContainerOptions struct {
	tc.ContainerOptions
}

ContainerOptions ...

type Options struct {
	Host               string
	Port               int64
	ExchangeName       string
	ExchangeRoutingKey string
}

Options for RabbitMQ...

func (options Options) ConnectionURI() string

ConnectionURI ...