Index

A

AccessRefused ack() (asynqp.IncomingMessage method) AMQPChannelError AMQPConnectionError AMQPError

arguments (asynqp.Queue attribute) asynqp (module) asynqp.exceptions (module) auto_delete (asynqp.Queue attribute)

B

bind() (asynqp.Queue method)

C

callback (asynqp.Consumer attribute) cancel() (asynqp.Consumer method) cancelled (asynqp.Consumer attribute) Channel (class in asynqp) ChannelClosed ChannelError close() (asynqp.Channel method) (asynqp.Connection method) CommandInvalid connect() (in module asynqp)

connect_and_open_channel() (in module asynqp) Connection (class in asynqp) ConnectionClosed ConnectionForced ConnectionLostError consume() (asynqp.Queue method) Consumer (class in asynqp) ContentTooLarge

D

declare_exchange() (asynqp.Channel method) declare_queue() (asynqp.Channel method) delete() (asynqp.Exchange method) (asynqp.Queue method)

Deleted durable (asynqp.Queue attribute)

E

exchange (asynqp.QueueBinding attribute) Exchange (class in asynqp)

exclusive (asynqp.Queue attribute)

F

FrameError

G

get() (asynqp.Queue method)

I

IncomingMessage (class in asynqp) InternalError

InvalidPath is_closed() (asynqp.Connection method)

J

json() (asynqp.Message method)

M

Message (class in asynqp)

N

name (asynqp.Exchange attribute) (asynqp.Queue attribute) NoConsumers NotAllowed

NotFound NotImplemented

O

open_channel() (asynqp.Connection method)

P

PreconditionFailed protocol (asynqp.Connection attribute)

publish() (asynqp.Exchange method) purge() (asynqp.Queue method)

Q

queue (asynqp.QueueBinding attribute) Queue (class in asynqp)

QueueBinding (class in asynqp)

R

reject() (asynqp.IncomingMessage method) ResourceError

ResourceLocked routing_key (asynqp.QueueBinding attribute)

S

set_qos() (asynqp.Channel method) set_return_handler() (asynqp.Channel method)

SyntaxError

T

tag (asynqp.Consumer attribute) transport (asynqp.Connection attribute)

type (asynqp.Exchange attribute)

U

unbind() (asynqp.QueueBinding method) UndeliverableMessage

UnexpectedFrame