Versions in this module Expand all Collapse all v3 v3.1.3 Dec 2, 2024 Changes in this version + const MQTT + const NatsCore + const NatsJetStream + const Redis + type MessageClient interface + Connect func() error + Disconnect func() error + Publish func(message types.MessageEnvelope, topic string) error + Request func(message types.MessageEnvelope, requestTopic string, responseTopicPrefix string, ...) (*types.MessageEnvelope, error) + Subscribe 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/v4
Go to main page