@staticmethod
    def _handle_amqp_frame(data_in):
        if not data_in:
            return data_in, None, None
        try:
            byte_count, channel_id, frame_in = pamqp_frame.unmarshal(data_in)
            return data_in[byte_count:], channel_id, frame_in
        except pamqp_exception.UnmarshalingException:
            return data_in, None, None
        except pamqp_spec.AMQPFrameError as why:
            LOGGER.error('AMQPFrameError: %r', why, exc_info=True)
            return data_in, None, None
Unmarshal any incoming RabbitMQ frames and return the result.
dataset/ETHPy150Open eandersson/amqpstorm/amqpstorm/connection.py/Connection._handle_amqp_frame