rabbitmq

Documentation

Overview

Package rabbitmq provides support for RabbitMQ message broker.

Index

• type MessageBroker
  • func NewMessageBroker(address string, opts ...cb.Option) *MessageBroker
  • func (b *MessageBroker) Dispose()
  • func (b MessageBroker) PublishMessage(ctx context.Context, m broker.Message) error
  • func (b MessageBroker) Subscribe(ctx context.Context, topic string) (<-chan broker.Message, error)

Types

type MessageBroker

type MessageBroker struct {
	Connection *amqp.Connection // amqp connection
}

MessageBroker represents message broker based on RabbitMQ.

func NewMessageBroker

func NewMessageBroker(address string, opts ...cb.Option) *MessageBroker

NewMessageBroker creates instance of RabbitMQ message broker which is connected on provided address. Additional options passed as arguments are used to configure circuit breaker pattern to connect to RabbitMQ instance. Panics if cannot create an instance.

func (*MessageBroker) Dispose

func (b *MessageBroker) Dispose()

Dispose closes RabbitMQ connection.

func (MessageBroker) PublishMessage

func (b MessageBroker) PublishMessage(ctx context.Context, m broker.Message) error

PublishMessage publishes message to RabbitMQ instance.

func (MessageBroker) Subscribe

func (b MessageBroker) Subscribe(ctx context.Context, topic string) (<-chan broker.Message, error)

Subscribe subscribes to specified routing key/topic in RabbitMQ instance.