pamqp.header¶

AMQP Header Class Definitions

For encoding AMQP Header frames into binary AMQP stream data and decoding AMQP binary data into AMQP Header frames.

class pamqp.header.ProtocolHeader(major_version=0, minor_version=9, revision=1)[source]¶

Class that represents the AMQP Protocol Header

Parameters

major_version (int) –
minor_version (int) –
revision (int) –

marshal()[source]¶

Return the full AMQP wire protocol frame data representation of the ProtocolHeader frame.

Return type: bytes

unmarshal(data)[source]¶

Dynamically decode the frame data applying the values to the method object by iterating through the attributes in order and decoding them.

Parameters: data (bytes) – The frame value to unpack
Raises: ValueError
Return type: int

class pamqp.header.ContentHeader(weight=0, body_size=0, properties=None)[source]¶

Represent a content header frame

A Content Header frame is received after a Basic.Deliver or Basic.GetOk frame and has the data and properties for the Content Body frames that follow.

Parameters

weight (int) –
body_size (int) –
properties (typing.Optional[pamqp.commands.Basic.Properties]) –

marshal()[source]¶

Return the AMQP binary encoded value of the frame

Return type: bytes

unmarshal(data)[source]¶

Dynamically decode the frame data applying the values to the method object by iterating through the attributes in order and decoding them.

Parameters: data (bytes) – The raw frame data to unmarshal
Return type: None