Index

_

__init__() (rabbitpy.Queue method) __iter__() (rabbitpy.Queue method)

__len__() (rabbitpy.Queue method) __setattr__() (rabbitpy.Queue method)

A

ack() (rabbitpy.Message method) ActionException AMQP (class in rabbitpy) AMQPAccessRefused AMQPChannelError AMQPCommandInvalid AMQPConnectionForced AMQPContentTooLarge AMQPException AMQPFrameError AMQPInternalError

AMQPInvalidPath AMQPNoConsumers AMQPNoRoute AMQPNotAllowed AMQPNotFound AMQPNotImplemented AMQPPreconditionFailed AMQPResourceError AMQPResourceLocked AMQPSyntaxError AMQPUnexpectedFrame args (rabbitpy.Connection property)

B

basic_ack() (rabbitpy.AMQP method) basic_cancel() (rabbitpy.AMQP method) basic_consume() (rabbitpy.AMQP method) basic_get() (rabbitpy.AMQP method) basic_nack() (rabbitpy.AMQP method) basic_publish() (rabbitpy.AMQP method) basic_qos() (rabbitpy.AMQP method) basic_recover() (rabbitpy.AMQP method)

basic_reject() (rabbitpy.AMQP method) bind() (rabbitpy.DirectExchange method) (rabbitpy.Exchange method) (rabbitpy.FanoutExchange method) (rabbitpy.HeadersExchange method) (rabbitpy.Queue method) (rabbitpy.TopicExchange method) blocked (rabbitpy.Connection property)

C

capabilities (rabbitpy.Connection property) Channel (class in rabbitpy) channel() (rabbitpy.Connection method) ChannelClosedException close() (rabbitpy.Channel method) (rabbitpy.Connection method) commit() (rabbitpy.Tx method) confirm_select() (rabbitpy.AMQP method) Connection (class in rabbitpy) ConnectionClosed

ConnectionException ConnectionResetException consume() (in module rabbitpy.simple) (rabbitpy.Queue method) consume_messages() (rabbitpy.Queue method) consumer() (rabbitpy.Queue method) create_direct_exchange() (in module rabbitpy.simple) create_fanout_exchange() (in module rabbitpy.simple) create_headers_exchange() (in module rabbitpy.simple) create_queue() (in module rabbitpy.simple) create_topic_exchange() (in module rabbitpy.simple)

D

declare() (rabbitpy.DirectExchange method) (rabbitpy.Exchange method) (rabbitpy.FanoutExchange method) (rabbitpy.HeadersExchange method) (rabbitpy.Queue method) (rabbitpy.TopicExchange method) delete() (rabbitpy.DirectExchange method) (rabbitpy.Exchange method) (rabbitpy.FanoutExchange method) (rabbitpy.HeadersExchange method) (rabbitpy.Queue method) (rabbitpy.TopicExchange method)

delete_exchange() (in module rabbitpy.simple) delete_queue() (in module rabbitpy.simple) delivery_tag (rabbitpy.Message property) DirectExchange (class in rabbitpy)

E

enable_publisher_confirms() (rabbitpy.Channel method) Exchange (class in rabbitpy) exchange (rabbitpy.Message property)

exchange_bind() (rabbitpy.AMQP method) exchange_declare() (rabbitpy.AMQP method) exchange_delete() (rabbitpy.AMQP method) exchange_unbind() (rabbitpy.AMQP method)

F

FanoutExchange (class in rabbitpy)

G

get() (in module rabbitpy.simple) (rabbitpy.Queue method)

H

ha_declare() (rabbitpy.Queue method)

HeadersExchange (class in rabbitpy)

I

id (rabbitpy.Channel property)

J

json() (rabbitpy.Message method)

M

maximum_frame_size (rabbitpy.Channel property) Message (class in rabbitpy) MessageReturnedException

module rabbitpy.exceptions rabbitpy.simple

N

nack() (rabbitpy.Message method) NoActiveTransactionError

NotConsumingError NotSupportedError

O

open() (rabbitpy.Channel method)

P

pprint() (rabbitpy.Message method) prefetch_count() (rabbitpy.Channel method) prefetch_size() (rabbitpy.Channel method) publish() (in module rabbitpy.simple) (rabbitpy.Message method)

publisher_confirms (rabbitpy.Channel property) purge() (rabbitpy.Queue method) Python Enhancement Proposals PEP 0343, [1], [2]

Q

Queue (class in rabbitpy) queue_bind() (rabbitpy.AMQP method) queue_declare() (rabbitpy.AMQP method)

queue_delete() (rabbitpy.AMQP method) queue_purge() (rabbitpy.AMQP method) queue_unbind() (rabbitpy.AMQP method)

R

rabbitpy.exceptions module rabbitpy.simple module RabbitpyException recover() (rabbitpy.Channel method)

redelivered (rabbitpy.Message property) reject() (rabbitpy.Message method) RemoteCancellationException RemoteClosedChannelException RemoteClosedException rollback() (rabbitpy.Tx method) routing_key (rabbitpy.Message property)

S

select() (rabbitpy.Tx method) server_properties (rabbitpy.Connection property)

SimpleChannel (class in rabbitpy.simple) stop_consuming() (rabbitpy.Queue method)

T

TooManyChannelsError TopicExchange (class in rabbitpy) Tx (class in rabbitpy)

tx_commit() (rabbitpy.AMQP method) tx_rollback() (rabbitpy.AMQP method) tx_select() (rabbitpy.AMQP method)

U

unbind() (rabbitpy.DirectExchange method) (rabbitpy.Exchange method) (rabbitpy.FanoutExchange method) (rabbitpy.HeadersExchange method) (rabbitpy.Queue method) (rabbitpy.TopicExchange method)

UnexpectedResponseError