| #!/usr/bin/env node |
| |
| var amqp = require('amqplib/callback_api'); |
| |
| function bail(err, conn) { |
| console.error(err); |
| if (conn) conn.close(function() { process.exit(1); }); |
| } |
| |
| function on_connect(err, conn) { |
| if (err !== null) return bail(err); |
| |
| var ex = 'logs'; |
| |
| function on_channel_open(err, ch) { |
| if (err !== null) return bail(err, conn); |
| ch.assertExchange(ex, 'fanout', {durable: false}); |
| var msg = process.argv.slice(2).join(' ') || |
| 'info: Hello World!'; |
| ch.publish(ex, '', Buffer.from(msg)); |
| console.log(" [x] Sent '%s'", msg); |
| ch.close(function() { conn.close(); }); |
| } |
| |
| conn.createChannel(on_channel_open); |
| } |
| |
| amqp.connect(on_connect); |