-
Notifications
You must be signed in to change notification settings - Fork 20
/
Copy pathnew_task.js
33 lines (33 loc) · 1.1 KB
/
new_task.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
'use strict';
const bramqp = require('bramqp');
const net = require('net');
const async = require('async');
const socket = net.connect({
port: 5672
});
bramqp.initialize(socket, 'rabbitmq/full/amqp0-9-1.stripped.extended', function(error, handle) {
async.series([function(seriesCallback) {
handle.openAMQPCommunication('guest', 'guest', true, seriesCallback);
}, function(seriesCallback) {
handle.queue.declare(1, 'task_queue', false, true, false, false, false, {});
handle.once('1:queue.declare-ok', function(channel, method, data) {
console.log('queue declared');
seriesCallback();
});
}, function(seriesCallback) {
const args = process.argv.splice(2);
const message = args.length ? args.join(' ') : 'Hello World!';
handle.basic.publish(1, '', 'task_queue', false, false, function() {
handle.content(1, 'basic', {
delivery_mode: 2
}, message, seriesCallback);
});
}, function(seriesCallback) {
handle.closeAMQPCommunication(seriesCallback);
}, function(seriesCallback) {
handle.socket.end();
setImmediate(seriesCallback);
}], function() {
console.log('all done');
});
});