This document is for py-amqp's development version, which can be significantly different from previous releases. Get the stable docs here: 2.4.

amqp.spec

AMQP Spec.

class amqp.spec.Basic[source]

AMQ Basic class.

Ack = (60, 80)
CLASS_ID = 60
Cancel = (60, 30)
CancelOk = (60, 31)
Consume = (60, 20)
ConsumeOk = (60, 21)
Deliver = (60, 60)
Get = (60, 70)
GetEmpty = (60, 72)
GetOk = (60, 71)
Nack = (60, 120)
Publish = (60, 40)
Qos = (60, 10)
QosOk = (60, 11)
Recover = (60, 110)
RecoverAsync = (60, 100)
RecoverOk = (60, 111)
Reject = (60, 90)
Return = (60, 50)
class amqp.spec.Channel[source]

AMQ Channel class.

CLASS_ID = 20
Close = (20, 40)
CloseOk = (20, 41)
Flow = (20, 20)
FlowOk = (20, 21)
Open = (20, 10)
OpenOk = (20, 11)
class amqp.spec.Confirm[source]

AMQ Confirm class.

CLASS_ID = 85
Select = (85, 10)
SelectOk = (85, 11)
class amqp.spec.Connection[source]

AMQ Connection class.

Blocked = (10, 60)
CLASS_ID = 10
Close = (10, 50)
CloseOk = (10, 51)
Open = (10, 40)
OpenOk = (10, 41)
Secure = (10, 20)
SecureOk = (10, 21)
Start = (10, 10)
StartOk = (10, 11)
Tune = (10, 30)
TuneOk = (10, 31)
Unblocked = (10, 61)
class amqp.spec.Exchange[source]

AMQ Exchange class.

Bind = (40, 30)
BindOk = (40, 31)
CLASS_ID = 40
Declare = (40, 10)
DeclareOk = (40, 11)
Delete = (40, 20)
DeleteOk = (40, 21)
Unbind = (40, 40)
UnbindOk = (40, 51)
class amqp.spec.Queue[source]

AMQ Queue class.

Bind = (50, 20)
BindOk = (50, 21)
CLASS_ID = 50
Declare = (50, 10)
DeclareOk = (50, 11)
Delete = (50, 40)
DeleteOk = (50, 41)
Purge = (50, 30)
PurgeOk = (50, 31)
Unbind = (50, 50)
UnbindOk = (50, 51)
class amqp.spec.Tx[source]

AMQ Tx class.

CLASS_ID = 90
Commit = (90, 20)
CommitOk = (90, 21)
Rollback = (90, 30)
RollbackOk = (90, 31)
Select = (90, 10)
SelectOk = (90, 11)
amqp.spec.method(method_sig, args=None, content=False)[source]

Create amqp method specification tuple.

class amqp.spec.method_t(method_sig, args, content)
args

Alias for field number 1

content

Alias for field number 2

method_sig

Alias for field number 0