communications

Documentation

Index

• 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

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