rabbitmq

Documentation

Index

• func AddQueueMapper(rmq *RabbitMQ, queues QueueMapper) error
• func Close(session *RabbitMQ) error
• type QueueMapper
• type RabbitMQ
  • func Open(uri string, exchange string, logger roles.Logger, consumeCycle context.Context) (*RabbitMQ, error)
  • func (r *RabbitMQ) AddExchange(name string) error
  • func (r *RabbitMQ) AddQueue(name messages.Recipient) error
  • func (r *RabbitMQ) AddQueueEventBind(queue messages.Recipient, bindingKey, routingKey messages.Key, ...) error
  • func (r *RabbitMQ) Consume(key messages.Key, queue *Recipient, deliveries <-chan amqp.Delivery, ...)
  • func (r *RabbitMQ) Publish(event *messages.Message) error
  • func (r *RabbitMQ) Subscribe(key messages.Key, consumer roles.EventConsumer) error
  • func (r *RabbitMQ) Unmarshal(data []byte, attributes, meta reflect.Type, event *messages.Message) error
• type Recipient

Functions

func AddQueueMapper

func AddQueueMapper(rmq *RabbitMQ, queues QueueMapper) error

func Close

func Close(session *RabbitMQ) error

Types

type QueueMapper

type QueueMapper map[messages.Key]*Recipient

type RabbitMQ

type RabbitMQ struct {
	*amqp.Connection
	*amqp.Channel
	roles.Logger
	ConsumeCycle context.Context
	// contains filtered or unexported fields
}

func Open

func Open(uri string, exchange string, logger roles.Logger, consumeCycle context.Context) (*RabbitMQ, error)

func (*RabbitMQ) AddExchange

func (r *RabbitMQ) AddExchange(name string) error

func (*RabbitMQ) AddQueue

func (r *RabbitMQ) AddQueue(name messages.Recipient) error

func (*RabbitMQ) AddQueueEventBind

func (r *RabbitMQ) AddQueueEventBind(queue messages.Recipient, bindingKey, routingKey messages.Key, attributes, meta reflect.Type) error

func (*RabbitMQ) Consume

func (r *RabbitMQ) Consume(key messages.Key, queue *Recipient, deliveries <-chan amqp.Delivery, consumer roles.EventConsumer)

func (*RabbitMQ) Publish

func (r *RabbitMQ) Publish(event *messages.Message) error

func (*RabbitMQ) Subscribe

func (r *RabbitMQ) Subscribe(key messages.Key, consumer roles.EventConsumer) error

func (*RabbitMQ) Unmarshal

func (r *RabbitMQ) Unmarshal(data []byte, attributes, meta reflect.Type, event *messages.Message) error

type Recipient

type Recipient struct {
	Name             messages.Recipient
	BindingKey       messages.Key
	Attributes, Meta reflect.Type
}