This document describes the current stable version of py-amqp (2.2). For development docs, go here.

amqp.spec

AMQP Spec.

class amqp.spec.Basic

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

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

AMQ Confirm class.

CLASS_ID = 85

Select = (85, 10)

SelectOk = (85, 11)

class amqp.spec.Connection

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

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

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

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)

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