PhpAmqpLib/Channel/AMQPChannel.php
protected function basic_deliver($reader, $message)
    {
        $consumer_tag = $reader->read_shortstr();
        $delivery_tag = $reader->read_longlong();
        $redelivered = $reader->read_bit();
        $exchange = $reader->read_shortstr();
        $routing_key = $reader->read_shortstr();

        $message->delivery_info = array(
            'channel' => $this,
            'consumer_tag' => $consumer_tag,
            'delivery_tag' => $delivery_tag,
            'redelivered' => $redelivered,
            'exchange' => $exchange,
            'routing_key' => $routing_key
        );

        if (isset($this->callbacks[$consumer_tag])) {
            call_user_func($this->callbacks[$consumer_tag], $message);
        }
    }
protected function basic_deliver($reader, $message)
    {
        $consumer_tag = $reader->read_shortstr();
        $delivery_tag = $reader->read_longlong();
        $redelivered = $reader->read_bit();
        $exchange = $reader->read_shortstr();
        $routing_key = $reader->read_shortstr();

        $message->delivery_info = array(
            'channel' => $this,
            'consumer_tag' => $consumer_tag,
            'delivery_tag' => $delivery_tag,
            'redelivered' => $redelivered,
            'exchange' => $exchange,
            'routing_key' => $routing_key
        );

        if (isset($this->callbacks[$consumer_tag])) {
            call_user_func($this->callbacks[$consumer_tag], $message);
        }
    }
protected function basic_deliver ( $ reader , $ message ) { $ consumer_tag = $ reader -> read_shortstr ( ) ; $ delivery_tag = $ reader -> read_longlong ( ) ; $ redelivered = $ reader -> read_bit ( ) ; $ exchange = $ reader -> read_shortstr ( ) ; $ routing_key = $ reader -> read_shortstr ( ) ; $ message -> delivery_info = array ( 'channel' => $ this , 'consumer_tag' => $ consumer_tag , 'delivery_tag' => $ delivery_tag , 'redelivered' => $ redelivered , 'exchange' => $ exchange , 'routing_key' => $ routing_key ) ; if ( isset ( $ this -> callbacks [ $ consumer_tag ] ) ) { call_user_func ( $ this -> callbacks [ $ consumer_tag ] , $ message ) ; } }
Notifies the client of a consumer message

@param AMQPReader $reader
@param AMQPMessage $message
Notifies the client of a consumer message