var open = require('amqplib').connect();
open.then(function(c) {
c.createConfirmChannel().then(function(ch) {
ch.sendToQueue('foo', new Buffer('foobar'), {},
function(err, ok) {
if (err !== null)
console.warn('Message nacked!');
else
console.log('Message acked');
});
});
});
var open = amqp.connect();
open.then(function(conn) {
process.once('SIGINT', conn.close.bind(conn));
return doStuffWithConnection(conn);
}).then(null, console.warn);
var open = amqp.connect();
open.then(function(conn) {
var ok = doStuffWithConnection(conn);
return ok.then(conn.close.bind(conn));
}).then(null, console.warn);
const sql = require('mssql')
sql.connect(config).then(() => {
return sql.query`select * from mytable where id = ${value}`
}).then(result => {
console.dir(result)
}).catch(err => {
// ... error checks
})
sql.on('error', err => {
// ... error handler
})
const sql = require('mssql')
(() => {
sql.connect().then(pool => {
return pool.query('SELECT 1')
}).then(result => {
// do something with result
}).then(() => {
return sql.close()
})
})()