Index

A

AbstractChannel (class in amqp.abstract_channel) AccessRefused amqp.abstract_channel (module) amqp.basic_message (module) amqp.channel (module) amqp.connection (module) amqp.exceptions (module) amqp.five (module) amqp.method_framing (module)

amqp.protocol (module) amqp.serialization (module) amqp.transport (module) amqp.utils (module) AMQPError AMQPNotImplementedError AMQPReader (class in amqp.serialization) AMQPWriter (class in amqp.serialization) args (amqp.utils.promise attribute)

B

basic_ack() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method) basic_cancel() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method) basic_consume() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method) basic_get() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method) basic_publish() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method) basic_publish_confirm() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method)

basic_qos() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method) basic_recover() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method) basic_recover_async() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method) basic_reject() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method) basic_return_t (class in amqp.protocol)

C

calls (amqp.utils.promise attribute) Channel (class in amqp.channel) channel() (amqp.connection.Connection method) channel_errors (amqp.connection.Connection attribute) ChannelError ChannelNotOpen client_heartbeat (amqp.connection.Connection attribute) close() (amqp.abstract_channel.AbstractChannel method) (amqp.channel.Channel method) (amqp.connection.Connection method) (amqp.connection.Connection.Channel method) (amqp.serialization.AMQPReader method) (amqp.serialization.AMQPWriter method) code (amqp.exceptions.AccessRefused attribute) (amqp.exceptions.AMQPError attribute) (amqp.exceptions.AMQPNotImplementedError attribute) (amqp.exceptions.ChannelNotOpen attribute) (amqp.exceptions.ConnectionForced attribute) (amqp.exceptions.ContentTooLarge attribute) (amqp.exceptions.FrameError attribute) (amqp.exceptions.FrameSyntaxError attribute) (amqp.exceptions.InternalError attribute) (amqp.exceptions.InvalidCommand attribute) (amqp.exceptions.InvalidPath attribute) (amqp.exceptions.NoConsumers attribute) (amqp.exceptions.NotAllowed attribute) (amqp.exceptions.NotFound attribute) (amqp.exceptions.PreconditionFailed attribute) (amqp.exceptions.ResourceError attribute) (amqp.exceptions.ResourceLocked attribute) (amqp.exceptions.UnexpectedFrame attribute) confirm_select() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method)

connected (amqp.connection.Connection attribute) Connection (class in amqp.connection) Connection.Channel (class in amqp.connection) connection_errors (amqp.connection.Connection attribute) ConnectionError ConnectionForced consumer_count (amqp.protocol.queue_declare_ok_t attribute) ConsumerCancelled ContentTooLarge create_transport() (in module amqp.transport)

D

dispatch_method() (amqp.abstract_channel.AbstractChannel method)

drain_events() (amqp.connection.Connection method)

E

exchange (amqp.protocol.basic_return_t attribute) exchange_bind() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method) exchange_declare() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method)

exchange_delete() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method) exchange_unbind() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method) exec_() (in module amqp.five)

F

failed (amqp.utils.promise attribute) flow() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method) flush() (amqp.serialization.AMQPWriter method)

FrameError FrameSyntaxError fun (amqp.utils.promise attribute)

G

GenericContent (class in amqp.serialization) get_errno() (in module amqp.utils)

getvalue() (amqp.serialization.AMQPWriter method)

H

heartbeat (amqp.connection.Connection attribute)

heartbeat_tick() (amqp.connection.Connection method)

I

InternalError InvalidCommand InvalidPath IrrecoverableChannelError

IrrecoverableConnectionError is_alive() (amqp.connection.Connection method) items() (in module amqp.five)

K

keys() (in module amqp.five)

kwargs (amqp.utils.promise attribute)

L

last_heartbeat_received (amqp.connection.Connection attribute)

last_heartbeat_sent (amqp.connection.Connection attribute)

M

message (amqp.protocol.basic_return_t attribute) Message (class in amqp.basic_message) message_count (amqp.protocol.queue_declare_ok_t attribute)

method (amqp.exceptions.AMQPError attribute) MethodReader (class in amqp.method_framing) monotonic() (in module amqp.five)

N

nextfun() (in module amqp.five) NoConsumers noop() (in module amqp.utils)

NotAllowed NotConfirmed NotFound

O

on_error (amqp.utils.promise attribute)

on_success (amqp.utils.promise attribute)

P

PreconditionFailed prev_recv (amqp.connection.Connection attribute) prev_sent (amqp.connection.Connection attribute)

promise (class in amqp.utils) PROPERTIES (amqp.basic_message.Message attribute) (amqp.serialization.GenericContent attribute)

Q

queue (amqp.protocol.queue_declare_ok_t attribute) queue_bind() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method) queue_declare() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method) queue_declare_ok_t (class in amqp.protocol)

queue_delete() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method) queue_purge() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method) queue_unbind() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method)

R

read() (amqp.serialization.AMQPReader method) read_array() (amqp.serialization.AMQPReader method) read_bit() (amqp.serialization.AMQPReader method) read_float() (amqp.serialization.AMQPReader method) read_item() (amqp.serialization.AMQPReader method) read_long() (amqp.serialization.AMQPReader method) read_longlong() (amqp.serialization.AMQPReader method) read_longstr() (amqp.serialization.AMQPReader method) read_method() (amqp.method_framing.MethodReader method) read_octet() (amqp.serialization.AMQPReader method) read_short() (amqp.serialization.AMQPReader method) read_shortstr() (amqp.serialization.AMQPReader method) read_table() (amqp.serialization.AMQPReader method)

read_timeout() (amqp.connection.Connection method) read_timestamp() (amqp.serialization.AMQPReader method) ready (amqp.utils.promise attribute) recoverable_channel_errors (amqp.connection.Connection attribute) recoverable_connection_errors (amqp.connection.Connection attribute) RecoverableChannelError RecoverableConnectionError reply_code (amqp.protocol.basic_return_t attribute) reply_text (amqp.protocol.basic_return_t attribute) reraise() (in module amqp.five) ResourceError ResourceLocked routing_key (amqp.protocol.basic_return_t attribute)

S

send_heartbeat() (amqp.connection.Connection method) server_capabilities (amqp.connection.Connection attribute) server_heartbeat (amqp.connection.Connection attribute) set_cloexec() (in module amqp.utils)

set_error_state() (amqp.utils.promise method) sock (amqp.connection.Connection attribute) SSLTransport (class in amqp.transport)

T

TCPTransport (class in amqp.transport) then() (amqp.utils.promise method) throw() (amqp.utils.promise method) timespec (class in amqp.five) Transport() (amqp.connection.Connection method)

tv_nsec (amqp.five.timespec attribute) tv_sec (amqp.five.timespec attribute) tx_commit() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method) tx_rollback() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method) tx_select() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method)

U

UnexpectedFrame

V

value (amqp.utils.promise attribute)

values() (in module amqp.five)

W

wait() (amqp.abstract_channel.AbstractChannel method) with_metaclass() (in module amqp.five) write() (amqp.serialization.AMQPWriter method) write_array() (amqp.serialization.AMQPWriter method) write_bit() (amqp.serialization.AMQPWriter method) write_item() (amqp.serialization.AMQPWriter method) write_long() (amqp.serialization.AMQPWriter method)

write_longlong() (amqp.serialization.AMQPWriter method) write_longstr() (amqp.serialization.AMQPWriter method) write_octet() (amqp.serialization.AMQPWriter method) write_short() (amqp.serialization.AMQPWriter method) write_shortstr() (amqp.serialization.AMQPWriter method) write_table() (amqp.serialization.AMQPWriter method) write_timestamp() (amqp.serialization.AMQPWriter method)