public function processMessage(BaseAMQPMessage $msg)
    {
        $newMsg = new AMQPMessage($msg->body, $msg->get_properties());
        $newMsg->delivery_info = $msg->delivery_info;
        $newMsg->body_size = $msg->body_size;
        $newMsg->is_truncated = $msg->is_truncated;
        $newMsg->setQueueName($this->queueName);

        $processFlag = call_user_func($this->callback, $newMsg);
        $this->handleProcessMessage($newMsg, $processFlag);
    }