client

Jul 16, 2021

Changes in this version

type Config

+ Logger func() stomp.Logger

Mar 25, 2021

Changes in this version

+ type Config interface

+ Authenticate func(login, passcode string) bool

+ HeartBeat func() time.Duration

+ type Conn struct

+ func NewConn(config Config, rw net.Conn, ch chan Request) *Conn

+ func (c *Conn) Send(f *frame.Frame)

+ func (c *Conn) SendError(err error)

+ type Request struct

+ Conn *Conn

+ Frame *frame.Frame

+ Op RequestOp

+ Sub *Subscription

+ type RequestOp int

+ const ConnectedOp

+ const DisconnectedOp

+ const EnqueueOp

+ const RequeueOp

+ const SubscribeOp

+ const UnsubscribeOp

+ func (r RequestOp) String() string

+ type Subscription struct

+ func (s *Subscription) Ack() string

+ func (s *Subscription) Destination() string

+ func (s *Subscription) Id() string

+ func (s *Subscription) IsAckedBy(msgId uint64) bool

+ func (s *Subscription) IsNackedBy(msgId uint64) bool

+ func (s *Subscription) SendQueueFrame(f *frame.Frame)

+ func (s *Subscription) SendTopicFrame(f *frame.Frame)

+ type SubscriptionList struct

+ func NewSubscriptionList() *SubscriptionList

+ func (sl *SubscriptionList) Ack(msgId uint64, callback func(s *Subscription))

+ func (sl *SubscriptionList) Add(sub *Subscription)

+ func (sl *SubscriptionList) FindByIdAndRemove(id string) *Subscription

+ func (sl *SubscriptionList) ForEach(callback func(s *Subscription, isLast bool))

+ func (sl *SubscriptionList) Get() *Subscription

+ func (sl *SubscriptionList) Nack(msgId uint64, callback func(s *Subscription))

+ func (sl *SubscriptionList) Remove(s *Subscription)