rabbit

type Channel interface {
	Confirm(noWait bool) error
	NotifyPublish(confirm chan amqp.Confirmation) chan amqp.Confirmation
	Publish(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error
	Close() error
}

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

type Consumer interface {
	// Topic return the topic that this worker want to listen to it
	Topic() string
	// Queue is the queue that this want to listen to
	Queue() string
	// Consume return a channel to put jobs into
	Consume(context.Context) chan<- Delivery
}

type Delivery interface {
	Decode(v interface{}) error
	// Ack delegates an acknowledgement through the Acknowledger interface that the client or server has finished work on a delivery.
	Ack(multiple bool) error
	// Nack negatively acknowledge the delivery of message(s) identified by the delivery tag from either the client or server.
	Nack(multiple, requeue bool) error
	// Reject delegates a negatively acknowledgement through the Acknowledger interface.
	Reject(requeue bool) error
}

type Job interface {
	Encode() ([]byte, error)
	Length() int
	Topic() string
}