rabbitmq

Documentation

Index

• 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 Config
  • func StartRabbitmqContainer(ctx context.Context, options ContainerOptions) (rabbitmqC testcontainers.Container, rabbitmqConfig Config, err error)
• type ConsumerOptions
• type ContainerOptions
• type Options
  • func (options Options) ConnectionURI() string

Functions

func Publish

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

Publish ...

func Setup

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

Setup ...

func SetupConsumer

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

SetupConsumer ...

Types

type Config

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

Config ...

func StartRabbitmqContainer

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

StartRabbitmqContainer ...

type ConsumerOptions

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

ConsumerOptions ...

type ContainerOptions

type ContainerOptions struct {
	tc.ContainerOptions
}

ContainerOptions ...

type Options

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

Options for RabbitMQ...

func (Options) ConnectionURI

func (options Options) ConnectionURI() string

ConnectionURI ...