Index

A

ack() (ammoo.Channel method) (ammoo.ExpectedMessage method) ammoo (module), [1], [2], [3], [4]

app_id (ammoo.wire.frames.header.BasicHeaderProperties attribute) assert_exchange_exists() (ammoo.Channel method) assert_queue_exists() (ammoo.Channel method)

B

BasicHeaderProperties (class in ammoo.wire.frames.header) bind_exchange() (ammoo.Channel method)

bind_queue() (ammoo.Channel method) body (ammoo.Message attribute)

C

Channel (class in ammoo) channel() (ammoo.Connection method) cluster_id (ammoo.wire.frames.header.BasicHeaderProperties attribute) connect() (in module ammoo) Connection (class in ammoo) consume() (ammoo.Channel method)

Consumer (class in ammoo) consumer_count (ammoo.wire.frames.method.queue.QueueDeclareOkParameters attribute) consumer_tag (ammoo.DeliverMessage attribute) content_encoding (ammoo.wire.frames.header.BasicHeaderProperties attribute) content_type (ammoo.wire.frames.header.BasicHeaderProperties attribute) correlation_id (ammoo.wire.frames.header.BasicHeaderProperties attribute)

D

declare_exchange() (ammoo.Channel method) declare_queue() (ammoo.Channel method) decode() (ammoo.Message method) delete_exchange() (ammoo.Channel method)

delete_queue() (ammoo.Channel method) DeliverMessage (class in ammoo) delivery_mode (ammoo.wire.frames.header.BasicHeaderProperties attribute) delivery_tag (ammoo.ExpectedMessage attribute)

E

exchange_name (ammoo.Message attribute)

ExpectedMessage (class in ammoo) expiration (ammoo.wire.frames.header.BasicHeaderProperties attribute)

G

get() (ammoo.Channel method)

GetMessage (class in ammoo)

H

headers (ammoo.wire.frames.header.BasicHeaderProperties attribute)

J

json() (ammoo.Message method)

M

Message (class in ammoo) message_count (ammoo.GetMessage attribute) (ammoo.wire.frames.method.queue.QueueDeclareOkParameters attribute)

message_id (ammoo.wire.frames.header.BasicHeaderProperties attribute)

P

priority (ammoo.wire.frames.header.BasicHeaderProperties attribute) properties (ammoo.Message attribute)

publish() (ammoo.Channel method) purge_queue() (ammoo.Channel method)

Q

qos() (ammoo.Channel method)

queue_name (ammoo.wire.frames.method.queue.QueueDeclareOkParameters attribute) QueueDeclareOkParameters (class in ammoo.wire.frames.method.queue)

R

recover() (ammoo.Channel method) reject() (ammoo.Channel method) (ammoo.ExpectedMessage method) reply() (ammoo.ExpectedMessage method)

reply_code (ammoo.ReturnMessage attribute) reply_text (ammoo.ReturnMessage attribute) reply_to (ammoo.wire.frames.header.BasicHeaderProperties attribute) ReturnMessage (class in ammoo) routing_key (ammoo.Message attribute)

S

select_confirm() (ammoo.Channel method)

T

timestamp (ammoo.wire.frames.header.BasicHeaderProperties attribute)

type_ (ammoo.wire.frames.header.BasicHeaderProperties attribute)

U

unbind_queue() (ammoo.Channel method)

user_id (ammoo.wire.frames.header.BasicHeaderProperties attribute)