Versions in this module Expand all Collapse all v0 v0.2.0 Feb 29, 2020 Changes in this version + var ErrCompletedSubscription = errors.New("subscription is unsubscribed") + type ConnProvider struct + func (p *ConnProvider) Conn() *stomp.Conn + func (p *ConnProvider) Register(conn *stomp.Conn) + func (p *ConnProvider) Replace(newConn *stomp.Conn, disconnectDelay time.Duration) + type Queue struct + Name string + Subscription *stomp.Subscription + type Subscription struct + func NewSubscription(name string, raw *stomp.Subscription) *Subscription + func (s *Subscription) Active() bool + func (s *Subscription) Queue() chan *jobworker.Job + func (s *Subscription) ReadLoop(conn jobworker.Connector) + func (s *Subscription) UnSubscribe() error
Go to main page