function Message(queue, message, headers, deliveryInfo) {
  // Crane uses slash ('/') separators rather than period ('.')
  this.queue = deliveryInfo.queue.replace(/\./g, '/');
  this.headers = {};
  if (deliveryInfo.contentType) { headers['content-type'] = deliveryInfo.contentType; }
  this.body = message;
  
  this._amqp = { queue: queue };
}

Message.prototype.ack = function() {
  this._amqp.queue.shift();
}


module.exports = Message;

function Message(queue, message, headers, deliveryInfo) {
  // Crane uses slash ('/') separators rather than period ('.')
  this.topic = deliveryInfo.routingKey.replace(/\./g, '/');
  this.headers = {};
  if (deliveryInfo.contentType) { headers['content-type'] = deliveryInfo.contentType; }
  this.body = message;
}


module.exports = Message;

Set topic based on routing key.
Set topic based on routing key.
