consumer

type AMQPChannel interface {
	Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error)
	Qos(prefetchCount, prefetchSize int, global bool) error
	NotifyClose(receiver chan *amqp.Error) chan *amqp.Error
	NotifyCancel(c chan string) chan string
	QueueDeclare(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error)
	QueueBind(name, key, exchange string, noWait bool, args amqp.Table) error
	Cancel(consumer string, noWait bool) error
	Close() error
}

type AMQPConnection interface {
}

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

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

type DefaultWorker struct {
	Logger logger.Logger
}

type Handler interface {
	Handle(ctx context.Context, msg amqp.Delivery) interface{}
}

type HandlerFunc func(ctx context.Context, msg amqp.Delivery) interface{}

type Middleware func(next Handler) Handler

type Option func(c *Consumer)

type ParallelWorker struct {
	Num    int
	Logger logger.Logger
}

type Ready struct {
	Queue string

	PrefetchCount int

	DeclareQueue      bool
	DeclareDurable    bool
	DeclareAutoDelete bool
	DeclareExclusive  bool
	DeclareNoWait     bool
	DeclareArgs       amqp.Table

	Consumer  string
	AutoAck   bool
	Exclusive bool
	NoLocal   bool
	NoWait    bool
	Args      amqp.Table
}

type State struct {
	Unready *Unready
	Ready   *Ready
}

type Unready struct {
	Err error
}

type Worker interface {
	Serve(ctx context.Context, h Handler, msgCh <-chan amqp.Delivery)
}