communications

Documentation

Index

• func CloseRabbitMQ(rmq *RabbitMQ) error
• func NewRabbitMQ(uri string, logger models.Logger) (messages.Broker, error)
• type BrokerMock
  • func (broker *BrokerMock) AddQueue(queue *messages.Queue) error
  • func (broker *BrokerMock) AddQueueConsumer(consumer messages.Consumer) error
  • func (broker *BrokerMock) AddQueueMessageBind(queue *messages.Queue, bindingKeys []string) error
  • func (broker *BrokerMock) AddRouter(router *messages.Router) error
  • func (broker *BrokerMock) PublishMessages(messages []*messages.Message) error
• type ConsumerMock
  • func (consumer *ConsumerMock) On(message *messages.Message) error
  • func (consumer *ConsumerMock) SubscribedTo() []*messages.Queue
• type RabbitMQ
  • func (rmq *RabbitMQ) AddQueue(queue *messages.Queue) error
  • func (rmq *RabbitMQ) AddQueueConsumer(consumer messages.Consumer) error
  • func (rmq *RabbitMQ) AddQueueMessageBind(queue *messages.Queue, bindingKeys []string) error
  • func (rmq *RabbitMQ) AddRouter(router *messages.Router) error
  • func (rmq *RabbitMQ) PublishMessages(messages []*messages.Message) error

Functions

func CloseRabbitMQ

func CloseRabbitMQ(rmq *RabbitMQ) error

func NewRabbitMQ

func NewRabbitMQ(uri string, logger models.Logger) (messages.Broker, error)

Types

type BrokerMock

type BrokerMock struct {
	mock.Mock
}

func (*BrokerMock) AddQueue

func (broker *BrokerMock) AddQueue(queue *messages.Queue) error

func (*BrokerMock) AddQueueConsumer

func (broker *BrokerMock) AddQueueConsumer(consumer messages.Consumer) error

func (*BrokerMock) AddQueueMessageBind

func (broker *BrokerMock) AddQueueMessageBind(queue *messages.Queue, bindingKeys []string) error

func (*BrokerMock) AddRouter

func (broker *BrokerMock) AddRouter(router *messages.Router) error

func (*BrokerMock) PublishMessages

func (broker *BrokerMock) PublishMessages(messages []*messages.Message) error

type ConsumerMock

type ConsumerMock struct {
	mock.Mock
}

func (*ConsumerMock) On

func (consumer *ConsumerMock) On(message *messages.Message) error

func (*ConsumerMock) SubscribedTo

func (consumer *ConsumerMock) SubscribedTo() []*messages.Queue

type RabbitMQ

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

func (*RabbitMQ) AddQueue

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

func (*RabbitMQ) AddQueueConsumer

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

func (*RabbitMQ) AddQueueMessageBind

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

func (*RabbitMQ) AddRouter

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

func (*RabbitMQ) PublishMessages

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