Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrNoQueueSpecified = errors.New("no queue specification specified")
)
Functions ¶
func WithNotifierHook ¶
func WithNotifierHook(fn wabbitiface.Notify) func(*Consumer)
Types ¶
type Consumer ¶
type Consumer struct {
// contains filtered or unexported fields
}
Consumer for queue
type Handler ¶
type Handler interface {
ProcessMessage(queueInfo *opts.QueueInfo, delivery wabbitiface.WrappedDelivery)
}
Click to show internal directories.
Click to hide internal directories.