pamqp.frame

Manage the marshaling and unmarshaling of AMQP frames

unmarshal will turn a raw AMQP byte stream into the appropriate AMQP objects from the specification file.

marshal will take an object created from the specification file and turn it into a raw byte stream.

pamqp.frame.marshal(frame_value, channel_id)

Marshal a frame to be sent over the wire.

Raises

ValueError

Parameters

• frame_value (typing.Union[pamqp.base.Frame, pamqp.body.ContentBody, pamqp.header.ContentHeader, pamqp.header.ProtocolHeader, pamqp.heartbeat.Heartbeat]) –

• channel_id (int) –

Return type

bytes

pamqp.frame.unmarshal(data_in)

Takes in binary data and maps builds the appropriate frame type, returning a frame object.

Return type

typing.Tuple[int, int, typing.Union[pamqp.base.Frame, pamqp.body.ContentBody, pamqp.header.ContentHeader, pamqp.header.ProtocolHeader, pamqp.heartbeat.Heartbeat]]

Returns

tuple of bytes consumed, channel, and a frame object

Raises

exceptions.UnmarshalingException

Parameters

data_in (bytes) –

pamqp.frame.frame_parts(data)

Attempt to decode a low-level frame, returning frame parts

Parameters

data (bytes) –

Return type

typing.Tuple[int, int, typing.Optional[int]]