PhpAmqpLib/Wire/AMQPReader.php
public function read_value($fieldType, $collectionsAsObjects = false)
    {
        $this->bitcount = $this->bits = 0;

        switch ($fieldType) {
            case AMQPAbstractCollection::T_INT_SHORTSHORT:
                //according to AMQP091 spec, 'b' is not bit, it is short-short-int, also valid for rabbit/qpid
                //$val=$this->read_bit();
                $val = $this->read_signed_octet();
                break;
            case AMQPAbstractCollection::T_INT_SHORTSHORT_U:
                $val = $this->read_octet();
                break;
            case AMQPAbstractCollection::T_INT_SHORT:
                $val = $this->read_signed_short();
                break;
            case AMQPAbstractCollection::T_INT_SHORT_U:
                $val = $this->read_short();
                break;
            case AMQPAbstractCollection::T_INT_LONG:
                $val = $this->read_signed_long();
                break;
            case AMQPAbstractCollection::T_INT_LONG_U:
                $val = $this->read_long();
                break;
            case AMQPAbstractCollection::T_INT_LONGLONG:
                $val = $this->read_signed_longlong();
                break;
            case AMQPAbstractCollection::T_INT_LONGLONG_U:
                $val = $this->read_longlong();
                break;
            case AMQPAbstractCollection::T_DECIMAL:
                $e = $this->read_octet();
                $n = $this->read_signed_long();
                $val = new AMQPDecimal($n, $e);
                break;
            case AMQPAbstractCollection::T_TIMESTAMP:
                $val = $this->read_timestamp();
                break;
            case AMQPAbstractCollection::T_BOOL:
                $val = $this->read_octet();
                break;
            case AMQPAbstractCollection::T_STRING_SHORT:
                $val = $this->read_shortstr();
                break;
            case AMQPAbstractCollection::T_STRING_LONG:
                $val = $this->read_longstr();
                break;
            case AMQPAbstractCollection::T_ARRAY:
                $val = $this->read_array($collectionsAsObjects);
                break;
            case AMQPAbstractCollection::T_TABLE:
                $val = $this->read_table($collectionsAsObjects);
                break;
            case AMQPAbstractCollection::T_VOID:
                $val = null;
                break;
            case AMQPAbstractCollection::T_BYTES:
                $val = $this->read_longstr();
                break;
            default:
                throw new AMQPInvalidArgumentException(sprintf(
                    'Unsupported type "%s"',
                    $fieldType
                ));
        }

        return isset($val) ? $val : null;
    }
public function read_value($fieldType, $collectionsAsObjects = false)
    {
        $this->bitcount = $this->bits = 0;

        switch ($fieldType) {
            case AMQPAbstractCollection::T_INT_SHORTSHORT:
                //according to AMQP091 spec, 'b' is not bit, it is short-short-int, also valid for rabbit/qpid
                //$val=$this->read_bit();
                $val = $this->read_signed_octet();
                break;
            case AMQPAbstractCollection::T_INT_SHORTSHORT_U:
                $val = $this->read_octet();
                break;
            case AMQPAbstractCollection::T_INT_SHORT:
                $val = $this->read_signed_short();
                break;
            case AMQPAbstractCollection::T_INT_SHORT_U:
                $val = $this->read_short();
                break;
            case AMQPAbstractCollection::T_INT_LONG:
                $val = $this->read_signed_long();
                break;
            case AMQPAbstractCollection::T_INT_LONG_U:
                $val = $this->read_long();
                break;
            case AMQPAbstractCollection::T_INT_LONGLONG:
                $val = $this->read_signed_longlong();
                break;
            case AMQPAbstractCollection::T_INT_LONGLONG_U:
                $val = $this->read_longlong();
                break;
            case AMQPAbstractCollection::T_DECIMAL:
                $e = $this->read_octet();
                $n = $this->read_signed_long();
                $val = new AMQPDecimal($n, $e);
                break;
            case AMQPAbstractCollection::T_TIMESTAMP:
                $val = $this->read_timestamp();
                break;
            case AMQPAbstractCollection::T_BOOL:
                $val = $this->read_octet();
                break;
            case AMQPAbstractCollection::T_STRING_SHORT:
                $val = $this->read_shortstr();
                break;
            case AMQPAbstractCollection::T_STRING_LONG:
                $val = $this->read_longstr();
                break;
            case AMQPAbstractCollection::T_ARRAY:
                $val = $this->read_array($collectionsAsObjects);
                break;
            case AMQPAbstractCollection::T_TABLE:
                $val = $this->read_table($collectionsAsObjects);
                break;
            case AMQPAbstractCollection::T_VOID:
                $val = null;
                break;
            case AMQPAbstractCollection::T_BYTES:
                $val = $this->read_longstr();
                break;
            default:
                throw new AMQPInvalidArgumentException(sprintf(
                    'Unsupported type "%s"',
                    $fieldType
                ));
        }

        return isset($val) ? $val : null;
    }
public function read_value ( $ fieldType , $ collectionsAsObjects = false ) { $ this -> bitcount = $ this -> bits = 0 ; switch ( $ fieldType ) { case AMQPAbstractCollection :: T_INT_SHORTSHORT : //according to AMQP091 spec, 'b' is not bit, it is short-short-int, also valid for rabbit/qpid //$val=$this->read_bit(); $ val = $ this -> read_signed_octet ( ) ; break ; case AMQPAbstractCollection :: T_INT_SHORTSHORT_U : $ val = $ this -> read_octet ( ) ; break ; case AMQPAbstractCollection :: T_INT_SHORT : $ val = $ this -> read_signed_short ( ) ; break ; case AMQPAbstractCollection :: T_INT_SHORT_U : $ val = $ this -> read_short ( ) ; break ; case AMQPAbstractCollection :: T_INT_LONG : $ val = $ this -> read_signed_long ( ) ; break ; case AMQPAbstractCollection :: T_INT_LONG_U : $ val = $ this -> read_long ( ) ; break ; case AMQPAbstractCollection :: T_INT_LONGLONG : $ val = $ this -> read_signed_longlong ( ) ; break ; case AMQPAbstractCollection :: T_INT_LONGLONG_U : $ val = $ this -> read_longlong ( ) ; break ; case AMQPAbstractCollection :: T_DECIMAL : $ e = $ this -> read_octet ( ) ; $ n = $ this -> read_signed_long ( ) ; $ val = new AMQPDecimal ( $ n , $ e ) ; break ; case AMQPAbstractCollection :: T_TIMESTAMP : $ val = $ this -> read_timestamp ( ) ; break ; case AMQPAbstractCollection :: T_BOOL : $ val = $ this -> read_octet ( ) ; break ; case AMQPAbstractCollection :: T_STRING_SHORT : $ val = $ this -> read_shortstr ( ) ; break ; case AMQPAbstractCollection :: T_STRING_LONG : $ val = $ this -> read_longstr ( ) ; break ; case AMQPAbstractCollection :: T_ARRAY : $ val = $ this -> read_array ( $ collectionsAsObjects ) ; break ; case AMQPAbstractCollection :: T_TABLE : $ val = $ this -> read_table ( $ collectionsAsObjects ) ; break ; case AMQPAbstractCollection :: T_VOID : $ val = null ; break ; case AMQPAbstractCollection :: T_BYTES : $ val = $ this -> read_longstr ( ) ; break ; default : throw new AMQPInvalidArgumentException ( sprintf ( 'Unsupported type "%s"' , $ fieldType ) ) ; } return isset ( $ val ) ? $ val : null ; }
Reads the next value as the provided field type.

@param int $fieldType One of AMQPAbstractCollection::T_* constants
@param bool $collectionsAsObjects Description
@return mixed
@throws \PhpAmqpLib\Exception\AMQPDataReadException
Reads the next value as the provided field type .