stan_util

Aug 4, 2021

Changes in this version

type DurableConnection

+ func (c *DurableConnection) Check() error

Jun 12, 2020

Changes in this version

+ type DurableConnection struct

+ func DurableConnect(stanClusterID, clientID, urls string, options ...stan.Option) (*DurableConnection, error)

+ func (c *DurableConnection) Close() error

+ func (c *DurableConnection) PublishAsync(subject string, data []byte, ah stan.AckHandler) (string, error)

+ func (c *DurableConnection) QueueSubscribe(subject, qgroup string, cb stan.MsgHandler, opts ...stan.SubscriptionOption) error