Index

_

_AbstractTransport (class in amqp.transport)

_wrap_context() (amqp.transport.SSLTransport method) _wrap_socket_sni() (amqp.transport.SSLTransport method)

A

AbstractChannel (class in amqp.abstract_channel) AccessRefused Ack (amqp.spec.Basic attribute) amqp.abstract_channel module amqp.basic_message module amqp.channel module amqp.connection module amqp.exceptions module amqp.method_framing module amqp.platform module

amqp.protocol module amqp.sasl module amqp.serialization module amqp.spec module amqp.transport module amqp.utils module AMQPDeprecationWarning AMQPError AMQPLAIN (class in amqp.sasl) AMQPNotImplementedError args (amqp.spec.method_t attribute)

B

Basic (class in amqp.spec) 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) Bind (amqp.spec.Exchange attribute) (amqp.spec.Queue attribute) BindOk (amqp.spec.Exchange attribute) (amqp.spec.Queue attribute) Blocked (amqp.spec.Connection attribute) blocking_read() (amqp.connection.Connection method) bytes_recv (amqp.connection.Connection attribute) bytes_sent (amqp.connection.Connection attribute) bytes_to_str() (in module amqp.utils)

C

Cancel (amqp.spec.Basic attribute) CancelOk (amqp.spec.Basic attribute) Channel (class in amqp.channel) (class in amqp.spec) channel() (amqp.connection.Connection method) channel_errors (amqp.connection.Connection attribute) ChannelError ChannelNotOpen CLASS_ID (amqp.basic_message.Message attribute) (amqp.serialization.GenericContent attribute) (amqp.spec.Basic attribute) (amqp.spec.Channel attribute) (amqp.spec.Confirm attribute) (amqp.spec.Connection attribute) (amqp.spec.Exchange attribute) (amqp.spec.Queue attribute) (amqp.spec.Tx attribute) client_heartbeat (amqp.connection.Connection attribute) Close (amqp.spec.Channel attribute) (amqp.spec.Connection attribute) close() (amqp.abstract_channel.AbstractChannel method) (amqp.channel.Channel method) (amqp.connection.Connection method) (amqp.connection.Connection.Channel method) (amqp.transport._AbstractTransport method) CloseOk (amqp.spec.Channel attribute) (amqp.spec.Connection attribute) 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)

collect() (amqp.channel.Channel method) (amqp.connection.Connection method) (amqp.connection.Connection.Channel method) Commit (amqp.spec.Tx attribute) CommitOk (amqp.spec.Tx attribute) Confirm (class in amqp.spec) confirm_select() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method) connect() (amqp.connection.Connection method) (amqp.transport._AbstractTransport method) connected (amqp.connection.Connection property) Connection (class in amqp.connection) (class in amqp.spec) Connection.Channel (class in amqp.connection) connection_errors (amqp.connection.Connection attribute) ConnectionError ConnectionForced Consume (amqp.spec.Basic attribute) ConsumeOk (amqp.spec.Basic attribute) consumer_count (amqp.protocol.queue_declare_ok_t attribute) ConsumerCancelled content (amqp.spec.method_t attribute) ContentTooLarge coro() (in module amqp.utils)

D

Declare (amqp.spec.Exchange attribute) (amqp.spec.Queue attribute) DeclareOk (amqp.spec.Exchange attribute) (amqp.spec.Queue attribute) decode_properties_basic() (in module amqp.serialization) Delete (amqp.spec.Exchange attribute) (amqp.spec.Queue attribute)

DeleteOk (amqp.spec.Exchange attribute) (amqp.spec.Queue attribute) Deliver (amqp.spec.Basic attribute) delivery_info (amqp.basic_message.Message attribute) delivery_tag (amqp.basic_message.Message property) dispatch_method() (amqp.abstract_channel.AbstractChannel method) drain_events() (amqp.connection.Connection method) dumps() (in module amqp.serialization)

E

exchange (amqp.protocol.basic_return_t attribute) Exchange (class in amqp.spec) 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) EXTERNAL (class in amqp.sasl)

F

Flow (amqp.spec.Channel attribute) flow() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method) FlowOk (amqp.spec.Channel attribute)

frame_handler() (in module amqp.method_framing) frame_writer (amqp.connection.Connection property) frame_writer() (in module amqp.method_framing) FrameError FrameSyntaxError

G

GenericContent (class in amqp.serialization) Get (amqp.spec.Basic attribute) get_logger() (in module amqp.utils)

GetEmpty (amqp.spec.Basic attribute) GetOk (amqp.spec.Basic attribute) GSSAPI (in module amqp.sasl)

H

having_timeout() (amqp.transport._AbstractTransport method) headers (amqp.basic_message.Message property)

heartbeat (amqp.connection.Connection attribute) heartbeat_tick() (amqp.connection.Connection method)

I

inbound_body() (amqp.serialization.GenericContent method) inbound_header() (amqp.serialization.GenericContent method) InternalError InvalidCommand

InvalidPath IrrecoverableChannelError IrrecoverableConnectionError is_alive() (amqp.connection.Connection method)

L

last_heartbeat_received (amqp.connection.Connection attribute) last_heartbeat_sent (amqp.connection.Connection attribute)

library_properties (amqp.connection.Connection attribute) loads() (in module amqp.serialization)

M

mechanism (amqp.sasl.AMQPLAIN attribute) (amqp.sasl.EXTERNAL attribute) (amqp.sasl.PLAIN attribute) (amqp.sasl.RAW attribute) (amqp.sasl.SASL property) message (amqp.protocol.basic_return_t attribute) Message (class in amqp.basic_message) message_count (amqp.protocol.queue_declare_ok_t attribute) MessageNacked method (amqp.exceptions.AMQPError property) method() (in module amqp.spec) method_sig (amqp.spec.method_t attribute) method_t (class in amqp.spec)

module amqp.abstract_channel amqp.basic_message amqp.channel amqp.connection amqp.exceptions amqp.method_framing amqp.platform amqp.protocol amqp.sasl amqp.serialization amqp.spec amqp.transport amqp.utils

N

Nack (amqp.spec.Basic attribute) negotiate_capabilities (amqp.connection.Connection attribute)

NoConsumers NotAllowed NotFound

O

on_inbound_frame (amqp.connection.Connection property) on_inbound_method() (amqp.connection.Connection method) Open (amqp.spec.Channel attribute) (amqp.spec.Connection attribute)

open() (amqp.channel.Channel method) (amqp.connection.Connection.Channel method) OpenOk (amqp.spec.Channel attribute) (amqp.spec.Connection attribute)

P

PLAIN (class in amqp.sasl) PreconditionFailed prev_recv (amqp.connection.Connection attribute) prev_sent (amqp.connection.Connection attribute)

PROPERTIES (amqp.basic_message.Message attribute) (amqp.serialization.GenericContent attribute) Publish (amqp.spec.Basic attribute) Purge (amqp.spec.Queue attribute) PurgeOk (amqp.spec.Queue attribute)

Q

Qos (amqp.spec.Basic attribute) QosOk (amqp.spec.Basic attribute) queue (amqp.protocol.queue_declare_ok_t attribute) Queue (class in amqp.spec) 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

RAW (class in amqp.sasl) read_frame() (amqp.transport._AbstractTransport method) Recover (amqp.spec.Basic attribute) recoverable_channel_errors (amqp.connection.Connection attribute) recoverable_connection_errors (amqp.connection.Connection attribute) RecoverableChannelError RecoverableConnectionError RecoverAsync (amqp.spec.Basic attribute) RecoverOk (amqp.spec.Basic attribute)

Reject (amqp.spec.Basic attribute) reply_code (amqp.protocol.basic_return_t attribute) reply_text (amqp.protocol.basic_return_t attribute) ResourceError ResourceLocked Return (amqp.spec.Basic attribute) Rollback (amqp.spec.Tx attribute) RollbackOk (amqp.spec.Tx attribute) routing_key (amqp.protocol.basic_return_t attribute)

S

SASL (class in amqp.sasl) Secure (amqp.spec.Connection attribute) SecureOk (amqp.spec.Connection attribute) Select (amqp.spec.Confirm attribute) (amqp.spec.Tx attribute) SelectOk (amqp.spec.Confirm attribute) (amqp.spec.Tx attribute) send_heartbeat() (amqp.connection.Connection method) send_method() (amqp.abstract_channel.AbstractChannel method) server_capabilities (amqp.connection.Connection property) server_heartbeat (amqp.connection.Connection attribute)

set_cloexec() (in module amqp.utils) sock (amqp.connection.Connection property) SSLTransport (class in amqp.transport) Start (amqp.spec.Connection attribute) start() (amqp.sasl.AMQPLAIN method) (amqp.sasl.EXTERNAL method) (amqp.sasl.PLAIN method) (amqp.sasl.RAW method) (amqp.sasl.SASL method) StartOk (amqp.spec.Connection attribute) str_to_bytes() (in module amqp.utils)

T

TCPTransport (class in amqp.transport) then() (amqp.channel.Channel method) (amqp.connection.Connection method) (amqp.connection.Connection.Channel method) transport (amqp.connection.Connection property) Transport (class in amqp.transport) Transport() (amqp.connection.Connection method) Tune (amqp.spec.Connection attribute)

TuneOk (amqp.spec.Connection attribute) Tx (class in amqp.spec) 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

Unbind (amqp.spec.Exchange attribute) (amqp.spec.Queue attribute) UnbindOk (amqp.spec.Exchange attribute) (amqp.spec.Queue attribute)

Unblocked (amqp.spec.Connection attribute) UnexpectedFrame

W

wait() (amqp.abstract_channel.AbstractChannel method)

write() (amqp.transport._AbstractTransport method)