protected function sendReply($result, $client, $correlationId)
    {
        $this->setParameter('correlation_id', $correlationId);
        $reply = new AMQPMessage(
            $result,
            $this->getParameters()
        );
        $this->channel
            ->basic_publish($reply, '', $client);
    }