Versions in this module Expand all Collapse all v3 v3.1.3 Dec 2, 2024 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 Other modules containing this package github.com/agile-edge/go-mod-messaging/v4
Go to main page