messaging

Mar 6, 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)