public function addMessageToBatch($job, $data = '', $queue = null)
    {
        $queue = $this->prepareQueue($queue);
        $payload = new AMQPMessage($this->createPayload($job, $queue, $data), $this->messageProperties);
        $this->channel->batch_basic_publish($payload, $this->exchangeName, $this->getRoutingKey($queue));