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.frame_parts(data_in)

Try and decode a low-level AMQP frame and return the parts of the frame.

Parameters:data_in (bytes) – Raw byte stream data Return tuple:frame type, channel number, and frame data to decode

pamqp.frame.marshal(frame_value, channel_id)

Marshal a frame to be sent over the wire.

Parameters:

• frame_value (pamqp.specification.Frame or pamqp.heartbeat.Heartbeat) – The frame object to marshal
• channel_id (int) – The channel number to send the frame on

Return type:

str

Raises:

ValueError

pamqp.frame.unmarshal(data_in)

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

Parameters:data_in (bytes) – Raw byte stream data Return type:tuple of bytes consumed, channel, and a frame object Raises:specification.FrameError