Versions in this module Expand all Collapse all v4 v4.0.1 Mar 30, 2025 Changes in this version + const MQTT + const NatsCore + const NatsJetStream + type MessageClient interface + Connect func() error + Disconnect func() error + Publish func(message types.MessageEnvelope, topic string) error + PublishBinaryData func(data []byte, topic string) error + PublishWithSizeLimit func(message types.MessageEnvelope, topic string, limit int64) error + Request func(message types.MessageEnvelope, requestTopic string, responseTopicPrefix string, ...) (*types.MessageEnvelope, error) + Subscribe func(topics []types.TopicChannel, messageErrors chan error) error + SubscribeBinaryData func(topics []types.TopicChannel, messageErrors chan error) error + Unsubscribe func(topics ...string) error + func NewMessageClient(msgConfig types.MessageBusConfig) (MessageClient, error) Other modules containing this package github.com/agile-edge/go-mod-messaging/v3
Go to main page