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 events.Recipient) error
  • func (r *RabbitMQ) AddQueueEventBind(queue events.Recipient, bindingKey, routingKey events.Key, ...) error
  • func (r *RabbitMQ) Publish(event *events.Event) error
  • func (r *RabbitMQ) Subscribe(key events.Key, consumer events.Consumer) error
  • func (r *RabbitMQ) Unmarshal(data []byte, attributes, meta reflect.Type, event *events.Event) error
• type Recipient

Functions

func Close

func Close(session *RabbitMQ) error

Types

type Events

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

type Queues

type Queues = map[events.Key]*Recipient

type RabbitMQ

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

func Open

func Open(uri string, exchange string, queues Queues, logger loggers.Logger) (*RabbitMQ, error)

func (*RabbitMQ) AddExchange

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

func (*RabbitMQ) AddQueue

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

func (*RabbitMQ) AddQueueEventBind

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

func (*RabbitMQ) Publish

func (r *RabbitMQ) Publish(event *events.Event) error

func (*RabbitMQ) Subscribe

func (r *RabbitMQ) Subscribe(key events.Key, consumer events.Consumer) error

func (*RabbitMQ) Unmarshal

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

type Recipient

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