sub

Documentation

Index

• type Subscriber
  • func NewSubscriber(conn *amqp.Connection) (*Subscriber, error)
  • func (s *Subscriber) Close() error
  • func (s *Subscriber) StartSubscriberFunc(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, ...) (func(chan any), error)

Types

type Subscriber

type Subscriber struct {
	bindings.PubSubChannel
}

Subscriber's channel(nfrvr)

func NewSubscriber

func NewSubscriber(conn *amqp.Connection) (*Subscriber, error)

Create a freshly-baked subscriber(don't play god too much, those may be lightweight, yet not no-weight)

func (*Subscriber) Close

func (s *Subscriber) Close() error

Function to make consumer stop consuming early

func (*Subscriber) StartSubscriberFunc

func (s *Subscriber) StartSubscriberFunc(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args amqp.Table) (func(chan any), error)

Returns a function which takes in a chan, that should be placed in goroutine