public function processMessage(AMQPMessage $message)
    {
        try {
            $message->delivery_info['channel']
                ->basic_ack($message->delivery_info['delivery_tag']);
            $result = call_user_func($this->callback, $message->body);
            $this->sendReply($result, $message->get('reply_to'), $message->get('correlation_id'));
        } catch (AMQPRuntimeException $exception) {
            $this->sendReply(
                'error: ' . $exception->getMessage(),
                $message->get('reply_to'),
                $message->get('correlation_id')
            );
        } catch (AMQPInvalidArgumentException $exception) {
            $this->sendReply(
                'error: ' . $exception->getMessage(),
                $message->get('reply_to'),
                $message->get('correlation_id')
            );
        }
    }
public function processMessage(AMQPMessage $message)
    {
        try {
            $message->delivery_info['channel']
                ->basic_ack($message->delivery_info['delivery_tag']);
            $result = call_user_func($this->callback, $message->body);
            $this->sendReply($result, $message->get('reply_to'), $message->get('correlation_id'));
        } catch (AMQPRuntimeException $exception) {
            $this->sendReply(
                'error: ' . $exception->getMessage(),
                $message->get('reply_to'),
                $message->get('correlation_id')
            );
        } catch (AMQPInvalidArgumentException $exception) {
            $this->sendReply(
                'error: ' . $exception->getMessage(),
                $message->get('reply_to'),
                $message->get('correlation_id')
            );
        }
    }
public function processMessage ( AMQPMessage $ message ) { try { $ message -> delivery_info [ 'channel' ] -> basic_ack ( $ message -> delivery_info [ 'delivery_tag' ] ) ; $ result = call_user_func ( $ this -> callback , $ message -> body ) ; $ this -> sendReply ( $ result , $ message -> get ( 'reply_to' ) , $ message -> get ( 'correlation_id' ) ) ; } catch ( AMQPRuntimeException $ exception ) { $ this -> sendReply ( 'error: ' . $ exception -> getMessage ( ) , $ message -> get ( 'reply_to' ) , $ message -> get ( 'correlation_id' ) ) ; } catch ( AMQPInvalidArgumentException $ exception ) { $ this -> sendReply ( 'error: ' . $ exception -> getMessage ( ) , $ message -> get ( 'reply_to' ) , $ message -> get ( 'correlation_id' ) ) ; } }
Process message.

@param AMQPMessage $message
@throws \OutOfBoundsException
@throws \PhpAmqpLib\Exception\AMQPInvalidArgumentException
Process message .