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)[source]¶ 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
-
pamqp.frame.
unmarshal
(data_in)[source]¶ 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
) –