Adding timeout to stomp

Author: Swapnil Tailor

lib/stomp.js

@@ -110,6 +110,9 @@ function _connect(stomp) {
     } else {
         log.debug('Connecting to ' + stomp.host + ':' + stomp.port);
         stomp.socket = new net.Socket();
+        if(stomp.timeout) {
+          stomp.socket.setTimeout(stomp.timeout);
+        }
         stomp.socket.connect(stomp.port, stomp.host);
         _setupListeners(stomp);
     }
@@ -161,6 +164,11 @@ function _setupListeners(stomp) {
         log.debug("end");
     });
 
+    socket.on('timeout', function() {
+        log.debug('socket timed out');
+        stomp.emit("timeout");
+    }
+
     socket.on('error', function(error) {
         log.error(error.stack + 'error name: ' + error.name);
         stomp.emit("error", error);