- Added support for /temp-queue

Author: itayw

lib/stomp.js

@@ -210,7 +210,8 @@ var Stomp = module.exports = function () {
       }
     }
     else {
-      sendCommand('SUBSCRIBE', headers);
+      if (headers.destination.indexOf('/temp-queue/') === -1)
+        sendCommand('SUBSCRIBE', headers);
       subscribedTo[destination] = { enabled: true, callback: callback };
       log.debug('subscribed to: ' + destination + ' with headers ' + sys.inspect(headers));
     }
@@ -497,6 +498,7 @@ var Stomp = module.exports = function () {
    */
   var parseHeaders = function (rawHeaders) {
     log.debug('rawHeaders', rawHeaders);
+
     var headers = {};
     var headersSplit = rawHeaders.split('\n');
 
@@ -662,8 +664,13 @@ var Stomp = module.exports = function () {
    * @returns {Boolean}                   return *true* if the frame is a message; otherwise, *false*
    */
   var shouldRunMessageCallback = function (frame) {
-    var subscription = subscribedTo[frame.headers.destination];
-    if (frame.headers.destination !== null && subscription !== null) {
+    var subscription = null;
+    if (frame.headers.subscription)
+      subscription = subscribedTo[frame.headers.subscription];
+    else
+      subscription = subscribedTo[frame.headers.destination];
+
+    if (frame.headers.destination !== null && subscription !== null && typeof (subscription) !== 'undefined') {
       if (subscription.enabled && subscription.callback !== null && typeof(subscription.callback) === 'function') {
         subscription.callback(frame.body, frame.headers);
       }