Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- events.js:141
- throw er; // Unhandled 'error' event
- ^
- Error: Channel closed by server: 404 (NOT-FOUND) with message "NOT_FOUND - no queue 'asdfasdfb' in vhost '/'"
- at Channel.C.accept (/app/node_modules/amqplib/lib/channel.js:406:17)
- at Connection.mainAccept [as accept] (/app/node_modules/amqplib/lib/connection.js:63:33)
- at Socket.go (/app/node_modules/amqplib/lib/connection.js:476:48)
- at emitNone (events.js:67:13)
- at Socket.emit (events.js:166:7)
- at emitReadable_ (_stream_readable.js:411:10)
- at emitReadable (_stream_readable.js:405:7)
- at readableAddChunk (_stream_readable.js:157:11)
- at Socket.Readable.push (_stream_readable.js:110:10)
- at TCP.onread (net.js:523:20)
- amqp.connect( process.env.QUEUE_HOST , function(err, conn) {
- if (err) return reject(err);
- conn.createChannel(function(err, ch) {
- if (err) return reject(err);
- var check = new Promise(function(resolve, reject){
- <<< SPECIFICALLY THIS >>>
- ch.checkQueue(queue, function(err,ok){
- if (err != null){
- return reject(err);
- } else{
- return resolve(true);
- }
- })
- })
- var assert = new Promise(function(resolve, reject){
- ch.assertQueue( queue , assertOpt, function(err,ok){
- if (err != null){
- return reject(err);
- } else {
- return resolve(true);
- }
- });
- })
- Promise.all( [check,assert] ).then(function(values){
- console.log(values);
- if( ch.sendToQueue(queue, new Buffer( JSON.stringify( message ) ) , sendOptions) == true){
- return resolve('message added');
- }
- })
- });
- })
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement