kakserpom / phpdaemon

            return "\x01" . \pack('nN', $frame->frameChannelId, \strlen($payload)) . $payload . "\xce";

        }

        if ($frame instanceof Channel\ChannelFlowFrame) {

            $payload = "\x00\x14\x00\x14"

                . ($frame->active ? "\x01" : "\x00");

            return "\x01" . \pack('nN', $frame->frameChannelId, \strlen($payload)) . $payload . "\xce";

        }

        if ($frame instanceof Channel\ChannelFlowOkFrame) {

            $payload = "\x00\x14\x00\x15"

                . ($frame->active ? "\x01" : "\x00");

            return "\x01" . \pack('nN', $frame->frameChannelId, \strlen($payload)) . $payload . "\xce";

        }

        if ($frame instanceof Channel\ChannelFlowOkFrame) {

            $payload = "\x00\x14\x00\x15"

                . ($frame->active ? "\x01" : "\x00");

            return "\x01" . \pack('nN', $frame->frameChannelId, \strlen($payload)) . $payload . "\xce";

        }

        if ($frame instanceof Channel\ChannelCloseFrame) {

            $payload = "\x00\x14\x00\x28"

                . \pack('n', $frame->replyCode)

            return "\x01" . \pack('nN', $frame->frameChannelId, \strlen($payload)) . $payload . "\xce";

        }

        if ($frame instanceof Basic\BasicRecoverFrame) {

            $payload = "\x00\x3c\x00\x6e"

                . ($frame->requeue ? "\x01" : "\x00");

            return "\x01" . \pack('nN', $frame->frameChannelId, \strlen($payload)) . $payload . "\xce";

        }

        if ($frame instanceof Basic\BasicNackFrame) {

            $payload = "\x00\x3c\x00\x78"

                . \pack('J', $frame->deliveryTag)

        if ($frame instanceof Tx\TxRollbackFrame) {

            return "\x01" . \pack('n', $frame->frameChannelId) . "\x00\x00\x00\x04\x00\x5a\x00\x1e\xce";

        }

        if ($frame instanceof Confirm\ConfirmSelectFrame) {

            $payload = "\x00\x55\x00\x0a"

                . ($frame->nowait ? "\x01" : "\x00");

            return "\x01" . \pack('nN', $frame->frameChannelId, \strlen($payload)) . $payload . "\xce";

        }

        throw new AMQPProtocolException(

            sprintf('Frame %s not implemented yet', get_class($frame)));