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) auto_decode (amqp.abstract_channel.AbstractChannel attribute) (amqp.channel.Channel attribute) (amqp.connection.Connection attribute) (amqp.connection.Connection.Channel 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) body (amqp.basic_message.Message attribute) body_received (amqp.serialization.GenericContent attribute) body_size (amqp.serialization.GenericContent attribute) 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 (amqp.basic_message.Message attribute) Channel (class in amqp.channel) (class in amqp.spec) channel() (amqp.connection.Connection method) channel_errors (amqp.connection.Connection attribute) channel_id (amqp.abstract_channel.AbstractChannel attribute) (amqp.channel.Channel attribute) (amqp.connection.Connection attribute) (amqp.connection.Connection.Channel 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) connect_timeout (amqp.transport._AbstractTransport attribute) (amqp.transport.TCPTransport attribute) connected (amqp.connection.Connection property) connection (amqp.abstract_channel.AbstractChannel attribute) (amqp.channel.Channel attribute) (amqp.connection.Connection attribute) (amqp.connection.Connection.Channel attribute) (amqp.transport._AbstractTransport attribute) (amqp.transport.TCPTransport attribute) 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_args (amqp.serialization.GenericContent attribute)

frame_handler() (in module amqp.method_framing) frame_method (amqp.serialization.GenericContent attribute) 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) host (amqp.transport._AbstractTransport attribute) (amqp.transport.TCPTransport attribute)

I

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

IrrecoverableConnectionError is_alive() (amqp.connection.Connection method) is_closing (amqp.abstract_channel.AbstractChannel attribute) (amqp.channel.Channel attribute) (amqp.connection.Connection attribute) (amqp.connection.Connection.Channel attribute)

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_queue (amqp.abstract_channel.AbstractChannel attribute) (amqp.channel.Channel attribute) (amqp.connection.Connection attribute) (amqp.connection.Connection.Channel attribute)

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

password (amqp.sasl.AMQPLAIN attribute) (amqp.sasl.PLAIN attribute) PLAIN (class in amqp.sasl) port (amqp.transport._AbstractTransport attribute) (amqp.transport.TCPTransport attribute) PreconditionFailed prev_recv (amqp.connection.Connection attribute)

prev_sent (amqp.connection.Connection attribute) PROPERTIES (amqp.basic_message.Message attribute) (amqp.serialization.GenericContent attribute) properties (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

raise_on_initial_eintr (amqp.transport._AbstractTransport attribute) (amqp.transport.TCPTransport attribute) RAW (class in amqp.sasl) read_frame() (amqp.transport._AbstractTransport method) read_timeout (amqp.transport._AbstractTransport attribute) (amqp.transport.TCPTransport attribute) ready (amqp.serialization.GenericContent attribute) 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) (amqp.transport._AbstractTransport attribute) (amqp.transport.TCPTransport attribute)

socket_settings (amqp.transport._AbstractTransport attribute) (amqp.transport.TCPTransport attribute) sslopts (amqp.transport.SSLTransport attribute) 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 username (amqp.sasl.AMQPLAIN attribute) (amqp.sasl.PLAIN attribute)

W

wait() (amqp.abstract_channel.AbstractChannel method) write() (amqp.transport._AbstractTransport method)

write_timeout (amqp.transport._AbstractTransport attribute) (amqp.transport.TCPTransport attribute)