videlalvaro / php-amqplib

        $this->protocolVersion = self::getProtocolVersion();

        switch ($this->protocolVersion) {

            case self::PROTOCOL_091:

                self::$PROTOCOL_CONSTANTS_CLASS = 'PhpAmqpLib\Wire\Constants091';

                $c = self::$PROTOCOL_CONSTANTS_CLASS;

                $this->debug = new DebugHelper($c);

                $this->amqp_protocol_header = $c::$AMQP_PROTOCOL_HEADER;

                $this->protocolWriter = new Protocol091();

                $this->waitHelper = new Wait091();

                $this->methodMap = new MethodMap091();

                break;

            case self::PROTOCOL_080:

                self::$PROTOCOL_CONSTANTS_CLASS = 'PhpAmqpLib\Wire\Constants080';

                $c = self::$PROTOCOL_CONSTANTS_CLASS;

                $this->waitHelper = new Wait091();

                $this->methodMap = new MethodMap091();

                break;

            case self::PROTOCOL_080:

                self::$PROTOCOL_CONSTANTS_CLASS = 'PhpAmqpLib\Wire\Constants080';

                $c = self::$PROTOCOL_CONSTANTS_CLASS;

                $this->debug = new DebugHelper($c);

                $this->amqp_protocol_header = $c::$AMQP_PROTOCOL_HEADER;

                $this->protocolWriter = new Protocol080();

                $this->waitHelper = new Wait080();

                $this->methodMap = new MethodMap080();

                break;

            default:

                throw new AMQPRuntimeException(sprintf(

                    'Protocol: %s not implemented.',