amqp

Jun 13, 2018

Changes in this version

type Configuration

+ BuriedTimeout int

May 9, 2018

Changes in this version

+ var ErrConnectionFailed = errors.NewKind("failed to connect to RabbitMQ: %s")

+ var ErrOpenChannel = errors.NewKind("failed to open a channel: %s")

+ var ErrRepublishingJobs = errors.NewKind("couldn't republish some jobs : %s")

+ var ErrRetrievingHeader = errors.NewKind("error retrieving '%s' header from message %s")

+ func New(url string) (queue.Broker, error)

+ type Acknowledger struct

+ func (a *Acknowledger) Ack() error

+ func (a *Acknowledger) Reject(requeue bool) error

+ type Broker struct

+ func (b *Broker) Close() error

+ func (b *Broker) Queue(name string) (queue.Queue, error)

+ type Configuration struct

+ BackoffFactor float64

+ BackoffMax time.Duration

+ BackoffMin time.Duration

+ BuriedExchangeSuffix string

+ BuriedNonBlockingRetries int

+ BuriedQueueSuffix string

+ ErrorHeader string

+ RetriesHeader string

+ var DefaultConfiguration Configuration

+ type JobIter struct

+ func (i *JobIter) Close() error

+ func (i *JobIter) Next() (*queue.Job, error)

+ type Queue struct

+ func (q *Queue) Consume(advertisedWindow int) (queue.JobIter, error)

+ func (q *Queue) Publish(j *queue.Job) error

+ func (q *Queue) PublishDelayed(j *queue.Job, delay time.Duration) error

+ func (q *Queue) RepublishBuried(conditions ...queue.RepublishConditionFunc) error

+ func (q *Queue) Transaction(txcb queue.TxCallback) error