mocks

May 23, 2023

Changes in this version

+ type MessageClient struct

+ func NewMessageClient(t mockConstructorTestingTNewMessageClient) *MessageClient

+ func (_m *MessageClient) Connect() error

+ func (_m *MessageClient) Disconnect() error

+ func (_m *MessageClient) Publish(message types.MessageEnvelope, topic string) error

+ func (_m *MessageClient) Request(message types.MessageEnvelope, requestTopic string, responseTopicPrefix string, ...) (*types.MessageEnvelope, error)

+ func (_m *MessageClient) Subscribe(topics []types.TopicChannel, messageErrors chan error) error

+ func (_m *MessageClient) Unsubscribe(topics ...string) error