Advertisement
Guest User

Untitled

a guest
Oct 24th, 2016
60
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.60 KB | None | 0 0
  1. events.js:141
  2. throw er; // Unhandled 'error' event
  3. ^
  4.  
  5. Error: Channel closed by server: 404 (NOT-FOUND) with message "NOT_FOUND - no queue 'asdfasdfb' in vhost '/'"
  6. at Channel.C.accept (/app/node_modules/amqplib/lib/channel.js:406:17)
  7. at Connection.mainAccept [as accept] (/app/node_modules/amqplib/lib/connection.js:63:33)
  8. at Socket.go (/app/node_modules/amqplib/lib/connection.js:476:48)
  9. at emitNone (events.js:67:13)
  10. at Socket.emit (events.js:166:7)
  11. at emitReadable_ (_stream_readable.js:411:10)
  12. at emitReadable (_stream_readable.js:405:7)
  13. at readableAddChunk (_stream_readable.js:157:11)
  14. at Socket.Readable.push (_stream_readable.js:110:10)
  15. at TCP.onread (net.js:523:20)
  16.  
  17. amqp.connect( process.env.QUEUE_HOST , function(err, conn) {
  18.  
  19. if (err) return reject(err);
  20.  
  21. conn.createChannel(function(err, ch) {
  22.  
  23. if (err) return reject(err);
  24.  
  25. var check = new Promise(function(resolve, reject){
  26. <<< SPECIFICALLY THIS >>>
  27. ch.checkQueue(queue, function(err,ok){
  28. if (err != null){
  29. return reject(err);
  30. } else{
  31. return resolve(true);
  32. }
  33. })
  34. })
  35.  
  36. var assert = new Promise(function(resolve, reject){
  37. ch.assertQueue( queue , assertOpt, function(err,ok){
  38. if (err != null){
  39. return reject(err);
  40. } else {
  41. return resolve(true);
  42. }
  43. });
  44. })
  45.  
  46. Promise.all( [check,assert] ).then(function(values){
  47. console.log(values);
  48. if( ch.sendToQueue(queue, new Buffer( JSON.stringify( message ) ) , sendOptions) == true){
  49. return resolve('message added');
  50. }
  51. })
  52.  
  53. });
  54. })
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement