rabbitmq

Documentation

Index

• func Close(session *RabbitMQ) error
• type RabbitMQ
  • func Open(uri string, logger loggers.Logger) (*RabbitMQ, error)
  • func (rabbitMQ *RabbitMQ) AddQueue(queue *messages.Queue) error
  • func (rabbitMQ *RabbitMQ) AddQueueConsumer(consumer messages.Consumer) error
  • func (rabbitMQ *RabbitMQ) AddQueueMessageBind(queue *messages.Queue, bindingKeys []string) error
  • func (rabbitMQ *RabbitMQ) AddRouter(router *messages.Router) error
  • func (rabbitMQ *RabbitMQ) PublishMessages(messages []*messages.Message) error

Functions

func Close

func Close(session *RabbitMQ) error

Types

type RabbitMQ

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

func Open

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

func (*RabbitMQ) AddQueue

func (rabbitMQ *RabbitMQ) AddQueue(queue *messages.Queue) error

func (*RabbitMQ) AddQueueConsumer

func (rabbitMQ *RabbitMQ) AddQueueConsumer(consumer messages.Consumer) error

func (*RabbitMQ) AddQueueMessageBind

func (rabbitMQ *RabbitMQ) AddQueueMessageBind(queue *messages.Queue, bindingKeys []string) error

func (*RabbitMQ) AddRouter

func (rabbitMQ *RabbitMQ) AddRouter(router *messages.Router) error

func (*RabbitMQ) PublishMessages

func (rabbitMQ *RabbitMQ) PublishMessages(messages []*messages.Message) error