gistfile1.js

#!/usr/bin/env node

var amqp = require("amqp");

var hostOpts  = { host: 'local.vm', login: 'xxx', password: 'xxx' };
var queueName = "email.normal.send";

var connection = amqp.createConnection(hostOpts);
connection.on("ready", function() {
  // publish to the default exchange which routes to
  // the queue given in the message routing key
  connection.exchange("email", {durable: true, type: "direct", confirm: true}, function(exchange) {
    var i = 0;
    var pushMessage = function() {
      console.log("pushMessage");
      exchange.on("ack", pushMessage);
      exchange.publish(queueName, messageOptions,
        {contentType: "application/json", deliveryMode: 2});
      i++;
      console.log("pushed " + i);
    };
    pushMessage();
  });
});