iamqp

type Channel = amqp.Channel

type ConcreteChannel struct {
	*amqp.Channel
	// contains filtered or unexported fields
}

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

type Confirmation = amqp.Confirmation

type Consumer interface {
	Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args Table) (<-chan ExtDelivery, error)
}

type Delivery = amqp.Delivery

type Error = amqp.Error

type ExtChannel interface {
	Publisher
	Consumer
	Ack(tag uint64, multiple bool) error
	Cancel(consumer string, noWait bool) error
	Close() error
	Confirm(noWait bool) error
	ExchangeBind(destination, key, source string, noWait bool, args Table) error
	ExchangeDeclare(name, kind string, durable, autoDelete, internal, noWait bool, args Table) error
	ExchangeDeclarePassive(name, kind string, durable, autoDelete, internal, noWait bool, args Table) error
	ExchangeDelete(name string, ifUnused, noWait bool) error
	ExchangeUnbind(destination, key, source string, noWait bool, args Table) error
	Flow(active bool) error
	Get(queue string, autoAck bool) (msg ExtDelivery, ok bool, err error)
	Nack(tag uint64, multiple bool, requeue bool) error
	NotifyCancel(c chan string) chan string
	NotifyClose(c chan *Error) chan *Error
	NotifyConfirm(ack, nack chan uint64) (chan uint64, chan uint64)
	NotifyFlow(c chan bool) chan bool
	NotifyPublish(confirm chan Confirmation) chan Confirmation
	NotifyReturn(c chan Return) chan Return

	Qos(prefetchCount, prefetchSize int, global bool) error
	QueueBind(name, key, exchange string, noWait bool, args Table) error
	QueueDeclare(name string, durable, autoDelete, exclusive, noWait bool, args Table) (Queue, error)
	QueueDeclarePassive(name string, durable, autoDelete, exclusive, noWait bool, args Table) (Queue, error)
	QueueDelete(name string, ifUnused, ifEmpty, noWait bool) (int, error)
	QueueInspect(name string) (Queue, error)
	QueuePurge(name string, noWait bool) (int, error)
	QueueUnbind(name, key, exchange string, args Table) error
	Recover(requeue bool) error
	Reject(tag uint64, requeue bool) error
	Tx() error
	TxCommit() error
	TxRollback() error

	GetURI() (URI, bool)
}

type ExtDelivery interface {
	Raw() *Delivery
	AutoAck() bool
	Queue() string

	RunWithContext(ctx context.Context) (context.Context, func(err error))
	RunOnScopeWithContext(ctx context.Context, handler Handler)
}

type Handler func(context.Context, *Delivery) error

type InternalConsumer interface {
	RawConsume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args Table) (<-chan Delivery, error)
	WrapDelivery(delivery *Delivery, queue string, autoAck bool) ExtDelivery
}

type Publisher interface {
	PublishWithContext(ctx context.Context, exchange, key string, mandatory, immediate bool, msg Publishing) error
}

type Publishing = amqp.Publishing

type Queue = amqp.Queue

type Return = amqp.Return

type Table = amqp.Table

type URI = amqp.URI