communicationMock

Documentation

Index

• type BrokerMock
  • func NewBrokerMock() *BrokerMock
  • func (m *BrokerMock) AddExchange(exchange *exchange.Exchange)
  • func (m *BrokerMock) AddQueue(queue *queue.Queue)
  • func (m *BrokerMock) AddQueueConsumer(consumer model.Consumer)
  • func (m *BrokerMock) AddQueueMessageBind(queue *queue.Queue, bindingKeys []string)
  • func (m *BrokerMock) PublishMessages(messages []*message.Message)
• type ConsumerMock
  • func NewConsumerMock() *ConsumerMock
  • func (m *ConsumerMock) On(message *message.Message)
  • func (m *ConsumerMock) SubscribedTo() []*queue.Queue

Types

type BrokerMock

type BrokerMock struct {
	mock.Mock
}

func NewBrokerMock

func NewBrokerMock() *BrokerMock

func (*BrokerMock) AddExchange

func (m *BrokerMock) AddExchange(exchange *exchange.Exchange)

func (*BrokerMock) AddQueue

func (m *BrokerMock) AddQueue(queue *queue.Queue)

func (*BrokerMock) AddQueueConsumer

func (m *BrokerMock) AddQueueConsumer(consumer model.Consumer)

func (*BrokerMock) AddQueueMessageBind

func (m *BrokerMock) AddQueueMessageBind(queue *queue.Queue, bindingKeys []string)

func (*BrokerMock) PublishMessages

func (m *BrokerMock) PublishMessages(messages []*message.Message)

type ConsumerMock

type ConsumerMock struct {
	mock.Mock
}

func NewConsumerMock

func NewConsumerMock() *ConsumerMock

func (*ConsumerMock) On

func (m *ConsumerMock) On(message *message.Message)

func (*ConsumerMock) SubscribedTo

func (m *ConsumerMock) SubscribedTo() []*queue.Queue