Versions in this module Expand all Collapse all v4 v4.0.1 Mar 30, 2025 Changes in this version + type Connection struct + func NewConnection(t mockConstructorTestingTNewConnection) *Connection + func (_m *Connection) Drain() error + func (_m *Connection) PublishMsg(_a0 *nats.Msg) error + func (_m *Connection) QueueSubscribe(_a0 string, _a1 string, _a2 nats.MsgHandler) (*nats.Subscription, error) + type MarshallerUnmarshaller struct + func NewMarshallerUnmarshaller(t mockConstructorTestingTNewMarshallerUnmarshaller) *MarshallerUnmarshaller + func (_m *MarshallerUnmarshaller) Marshal(v types.MessageEnvelope, publishTopic string) (*nats.Msg, error) + func (_m *MarshallerUnmarshaller) Unmarshal(msg *nats.Msg, v *types.MessageEnvelope) error Other modules containing this package github.com/agile-edge/go-mod-messaging/v3
Go to main page