sub

Documentation

Index

• type Subscriber
  • func NewSubscriber(conn *amqp.Connection) (*Subscriber, error)
  • func (s *Subscriber) Close() error
  • func (s *Subscriber) StartSubscriberFunc(sp SubscriberPackage) (func(chan amqp.Delivery), error)
• type SubscriberPackage

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

func (*Subscriber) Close

func (s *Subscriber) Close() error

Function to make consumer stop consuming early

func (*Subscriber) StartSubscriberFunc

func (s *Subscriber) StartSubscriberFunc(sp SubscriberPackage) (func(chan amqp.Delivery), error)

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

type SubscriberPackage

type SubscriberPackage struct {
	Queue     string
	Consumer  string
	AutoAck   bool
	Exclusive bool
	NoLocal   bool
	NoWait    bool
	Args      amqp.Table
}