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

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 property) DirectExchange (class in rabbitpy)

E

enable_publisher_confirms() (rabbitpy.Channel method)

Exchange (class in rabbitpy) exchange() (rabbitpy.Message property)

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

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

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

S

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

server_properties() (rabbitpy.Connection property) 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