internal

Documentation

Index

• Variables
• type ConnProvider
  • 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
• type Subscription
  • 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

Variables

var ErrCompletedSubscription = errors.New("subscription is unsubscribed")

Types

type ConnProvider

type ConnProvider struct {
	// contains filtered or unexported fields
}

func (*ConnProvider) Conn

func (p *ConnProvider) Conn() *stomp.Conn

func (*ConnProvider) Register

func (p *ConnProvider) Register(conn *stomp.Conn)

func (*ConnProvider) Replace

func (p *ConnProvider) Replace(newConn *stomp.Conn, disconnectDelay time.Duration)

type Queue

type Queue struct {
	Name         string
	Subscription *stomp.Subscription
}

type Subscription

type Subscription struct {
	// contains filtered or unexported fields
}

func NewSubscription

func NewSubscription(name string,
	raw *stomp.Subscription) *Subscription

func (*Subscription) Active

func (s *Subscription) Active() bool

func (*Subscription) Queue

func (s *Subscription) Queue() chan *jobworker.Job

func (*Subscription) ReadLoop

func (s *Subscription) ReadLoop(conn jobworker.Connector)

func (*Subscription) UnSubscribe

func (s *Subscription) UnSubscribe() error