Skip to content

Instantly share code, notes, and snippets.

@DarcInc

DarcInc/gist:9641582

Last active August 29, 2015 13:57
Download ZIP

Revisions

  1. DarcInc revised this gist Mar 19, 2014. No changes.
  2. DarcInc revised this gist Mar 19, 2014. 1 changed file with 0 additions and 2 deletions.
    2 changes: 0 additions & 2 deletions gistfile1.js
    View file
    Original file line number Diff line number Diff line change
    @@ -1,8 +1,6 @@
    var queueName = 'tasks';


    var amq = require('amq');
    var server = amqp.connect("amqp://localhost");

    var connection = amq.createConnection(
    { host: 'localhost', debug: true },
  3. DarcInc created this gist Mar 19, 2014.
    16 changes: 16 additions & 0 deletions gistfile1.js
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,16 @@
    var queueName = 'tasks';


    var amq = require('amq');
    var server = amqp.connect("amqp://localhost");

    var connection = amq.createConnection(
    { host: 'localhost', debug: true },
    { reconnect: { strategy: 'constant', initial: 1000 } }
    );

    var queue = connection.queue(queueName, { durable: true });
    queue.consume(function(message) {
    console.log(message.content.toString());
    queue.ack(message);
    }).then(null, console.warn);