Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Acknowledger ¶
type Acknowledger struct {
// contains filtered or unexported fields
}
Acknowledger implements the Acknowledger for AMQP library.
func (*Acknowledger) Reject ¶
func (a *Acknowledger) Reject(requeue bool) error
Reject signals rejection. If requeue is false, the job will go to the buried queue until Queue.RepublishBuried() is called.
type RMQ ¶ added in v0.0.4
type RMQ struct {
// contains filtered or unexported fields
}
RMQ is a RabbitMQ consumer configuration Implement Consumer.Consumer interface
Click to show internal directories.
Click to hide internal directories.