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: Union[Frame, ContentBody, ContentHeader, ProtocolHeader, Heartbeat], channel_id: int) bytes [source]
Marshal a frame to be sent over the wire.
- Raises:
ValueError
- pamqp.frame.unmarshal(data_in: bytes) Tuple[int, int, Union[Frame, ContentBody, ContentHeader, ProtocolHeader, Heartbeat]] [source]
Takes in binary data and maps builds the appropriate frame type, returning a frame object.
- Returns:
tuple of bytes consumed, channel, and a frame object
- Raises:
exceptions.UnmarshalingException