mocks

Documentation

Index

• type IMessagingClient
  • func (_m *IMessagingClient) Close()
  • func (_m *IMessagingClient) ConnectToBroker(connectionString string)
  • func (_m *IMessagingClient) Publish(msg []byte, exchangeName string, exchangeType string) error
  • func (_m *IMessagingClient) PublishOnQueue(msg []byte, queueName string) error
  • func (_m *IMessagingClient) PublishOnQueueWaitReply(msg []byte, queueName string) ([]byte, error)
  • func (_m *IMessagingClient) Subscribe(exchangeName string, exchangeType string, consumerName string, ...) error
  • func (_m *IMessagingClient) SubscribeToQueue(queueName string, consumerName string, handlerFunc func(amqp.Delivery)) error
  • func (_m *IMessagingClient) SubscribeToQueueAndReply(queueName string, consumerName string, handlerFunc func(amqp.Delivery) []byte) error

Types

type IMessagingClient

type IMessagingClient struct {
	mock.Mock
}

IMessagingClient is an autogenerated mock type for the IMessagingClient type

func (*IMessagingClient) Close

func (_m *IMessagingClient) Close()

Close provides a mock function with given fields:

func (*IMessagingClient) ConnectToBroker

func (_m *IMessagingClient) ConnectToBroker(connectionString string)

ConnectToBroker provides a mock function with given fields: connectionString

func (*IMessagingClient) Publish

func (_m *IMessagingClient) Publish(msg []byte, exchangeName string, exchangeType string) error

Publish provides a mock function with given fields: msg, exchangeName, exchangeType

func (*IMessagingClient) PublishOnQueue

func (_m *IMessagingClient) PublishOnQueue(msg []byte, queueName string) error

PublishOnQueue provides a mock function with given fields: msg, queueName

func (*IMessagingClient) PublishOnQueueWaitReply

func (_m *IMessagingClient) PublishOnQueueWaitReply(msg []byte, queueName string) ([]byte, error)

PublishOnQueueWaitReply provides a mock function with given fields: msg, queueName

func (*IMessagingClient) Subscribe

func (_m *IMessagingClient) Subscribe(exchangeName string, exchangeType string, consumerName string, handlerFunc func(amqp.Delivery)) error

Subscribe provides a mock function with given fields: exchangeName, exchangeType, consumerName, handlerFunc

func (*IMessagingClient) SubscribeToQueue

func (_m *IMessagingClient) SubscribeToQueue(queueName string, consumerName string, handlerFunc func(amqp.Delivery)) error

SubscribeToQueue provides a mock function with given fields: queueName, consumerName, handlerFunc

func (*IMessagingClient) SubscribeToQueueAndReply

func (_m *IMessagingClient) SubscribeToQueueAndReply(queueName string, consumerName string, handlerFunc func(amqp.Delivery) []byte) error

SubscribeToQueueAndReply provides a mock function with given fields: queueName, consumerName, handlerFunc