Index

_

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

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

A

ack() (rabbitpy.Message method) ActionException AMQPAccessRefused AMQPChannelError AMQPCommandInvalid AMQPConnectionForced AMQPContentTooLarge AMQPFrameError AMQPInternalError AMQPInvalidPath

AMQPNoConsumers AMQPNoRoute AMQPNotAllowed AMQPNotFound AMQPNotImplemented AMQPPreconditionFailed AMQPResourceError AMQPResourceLocked AMQPSyntaxError AMQPUnexpectedFrame

B

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

blocked (rabbitpy.Connection attribute)

C

Channel (class in rabbitpy) channel() (rabbitpy.Connection method) ChannelClosedException close() (rabbitpy.Channel method) (rabbitpy.Connection method) commit() (rabbitpy.Tx method) Connection (class in rabbitpy) ConnectionException ConnectionResetException

consume() (in module rabbitpy.simple) 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 attribute) DirectExchange (class in rabbitpy)

E

enable_publisher_confirms() (rabbitpy.Channel method) Exchange (class in rabbitpy)

exchange (rabbitpy.Message attribute)

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 attribute)

J

json() (rabbitpy.Message method)

M

Message (class in rabbitpy)

MessageReturnedException

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 attribute) purge() (rabbitpy.Queue method) Python Enhancement Proposals PEP 0343, [1], [2]

Q

Queue (class in rabbitpy)

R

rabbitpy.exceptions (module) rabbitpy.simple (module) recover() (rabbitpy.Channel method) redelivered (rabbitpy.Message attribute) reject() (rabbitpy.Message method)

RemoteClosedChannelException RemoteClosedException rollback() (rabbitpy.Tx method) routing_key (rabbitpy.Message attribute)

S

select() (rabbitpy.Tx method) server_capabilities (rabbitpy.Connection attribute)

server_properties (rabbitpy.Connection attribute) stop_consuming() (rabbitpy.Queue method)

T

TooManyChannelsError TopicExchange (class in rabbitpy)

Tx (class in rabbitpy)

U

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

UnexpectedResponseError