Index

_

__init__() (amqpy.channel.Channel method) (amqpy.connection.Connection method) (amqpy.message.Message method) (amqpy.proto.Frame method) (amqpy.proto.Method method)

A

AccessRefused ack() (amqpy.message.Message method) active (amqpy.channel.Channel attribute) AMQPNotImplementedError amqpy.channel (module) amqpy.connection (module)

amqpy.consumer (module) amqpy.exceptions (module) amqpy.message (module) amqpy.proto (module) amqpy.spec (module) application_headers (amqpy.message.Message attribute)

B

basic_ack() (amqpy.channel.Channel method) basic_cancel() (amqpy.channel.Channel method) basic_consume() (amqpy.channel.Channel method) basic_get() (amqpy.channel.Channel method) basic_publish() (amqpy.channel.Channel method) basic_qos() (amqpy.channel.Channel method)

basic_recover() (amqpy.channel.Channel method) basic_recover_async() (amqpy.channel.Channel method) basic_reject() (amqpy.channel.Channel method) basic_return_t (class in amqpy.spec) body (amqpy.message.Message attribute)

C

CH_MODE_CONFIRM (amqpy.channel.Channel attribute) CH_MODE_NONE (amqpy.channel.Channel attribute) CH_MODE_TX (amqpy.channel.Channel attribute) channel (amqpy.message.Message attribute) (amqpy.proto.Frame attribute) Channel (class in amqpy.channel) channel() (amqpy.connection.Connection method) channel_id (amqpy.proto.Method attribute) ChannelNotOpen channels (amqpy.connection.Connection attribute)

close() (amqpy.channel.Channel method) (amqpy.connection.Connection method) complete (amqpy.proto.Method attribute) confirm_select() (amqpy.channel.Channel method) connect() (amqpy.connection.Connection method) connected (amqpy.connection.Connection attribute) Connection (class in amqpy.connection) ConnectionForced content (amqpy.proto.Method attribute) ContentTooLarge

D

data (amqpy.proto.Frame attribute) delivery_info (amqpy.message.Message attribute) delivery_tag (amqpy.message.Message attribute) drain_events() (amqpy.connection.Connection method)

dump_body_frame() (amqpy.proto.Method method) dump_header_frame() (amqpy.proto.Method method) dump_method_frame() (amqpy.proto.Method method)

E

exchange_bind() (amqpy.channel.Channel method) exchange_declare() (amqpy.channel.Channel method)

exchange_delete() (amqpy.channel.Channel method) exchange_unbind() (amqpy.channel.Channel method)

F

flow() (amqpy.channel.Channel method) Frame (class in amqpy.proto) FRAME_MIN_SIZE (in module amqpy.spec) frame_type (amqpy.proto.Frame attribute)

FrameError FrameSyntaxError FrameType (class in amqpy.spec)

I

InternalError InvalidCommand InvalidPath

is_alive() (amqpy.connection.Connection method) is_open (amqpy.channel.Channel attribute)

L

load_body_frame() (amqpy.proto.Method method) load_header_frame() (amqpy.proto.Method method)

load_method_frame() (amqpy.proto.Method method) loop() (amqpy.connection.Connection method)

M

Message (class in amqpy.message) Method (class in amqpy.proto) method_t (class in amqpy.spec)

method_type (amqpy.proto.Method attribute) mode (amqpy.channel.Channel attribute)

N

NoConsumers NotAllowed

NotFound

P

payload (amqpy.proto.Frame attribute) payload_size (amqpy.proto.Frame attribute)

PreconditionFailed

Q

queue_bind() (amqpy.channel.Channel method) queue_declare() (amqpy.channel.Channel method) queue_declare_ok_t (class in amqpy.spec)

queue_delete() (amqpy.channel.Channel method) queue_purge() (amqpy.channel.Channel method) queue_unbind() (amqpy.channel.Channel method)

R

reject() (amqpy.message.Message method) ResourceError

ResourceLocked returned_messages (amqpy.channel.Channel attribute)

S

send_heartbeat() (amqpy.connection.Connection method) server_capabilities (amqpy.connection.Connection attribute)

sock (amqpy.connection.Connection attribute)

T

Timeout transport (amqpy.connection.Connection attribute) tx_commit() (amqpy.channel.Channel method)

tx_rollback() (amqpy.channel.Channel method) tx_select() (amqpy.channel.Channel method)

U

UnexpectedFrame