rabbitmq

Documentation

Index

• func Close(session *RabbitMQ) error
• type Events
• type Queues
• type RabbitMQ
  • func Open(uri string, exchange string, queues Queues, logger loggers.Logger, ...) (*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 events.Consumer) error
  • func (r *RabbitMQ) Unmarshal(data []byte, attributes, meta reflect.Type, event *messages.Message) error
• type Recipient

Functions

func Close

func Close(session *RabbitMQ) error

Types

type Events

type Events = map[messages.Key][]events.Consumer

type Queues

type Queues = map[messages.Key]*Recipient

type RabbitMQ

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

func Open

func Open(uri string, exchange string, queues Queues, logger loggers.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 events.Consumer)

func (*RabbitMQ) Publish

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

func (*RabbitMQ) Subscribe

func (r *RabbitMQ) Subscribe(key messages.Key, consumer events.Consumer) 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
}