Versions in this module Expand all Collapse all v4 v4.0.1 Mar 30, 2025 Changes in this version + type MessageClient struct + func NewMessageClient(t interface{ ... }) *MessageClient + func (_m *MessageClient) Connect() error + func (_m *MessageClient) Disconnect() error + func (_m *MessageClient) Publish(message types.MessageEnvelope, topic string) error + func (_m *MessageClient) PublishBinaryData(data []byte, topic string) error + func (_m *MessageClient) PublishWithSizeLimit(message types.MessageEnvelope, topic string, limit int64) 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) SubscribeBinaryData(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/v3
Go to main page