emit an error event that must be caught by stomp users

Signed-off-by: Joshua Rubin <jrubin@zvelo.com>

Author: Joshua Rubin

lib/stomp.js

@@ -95,18 +95,18 @@ function _connect(stomp) {
     log = stomp.log;
 
     if (stomp.ssl) {
-      log.debug('Connecting to ' + stomp.host + ':' + stomp.port + ' using SSL');
-      stomp.socket = tls.connect(stomp.port, stomp.host, stomp.ssl_options, function() {
-          log.debug('SSL connection complete');
-          if (!stomp.socket.authorized) {
-              log.error('SSL is not authorized: '+stomp.socket.authorizationError);
-              if (stomp.ssl_validate) {
-                  _disconnect(stomp);
-                  return;
-              }
-          }
-          _setupListeners(stomp);
-      });
+        log.debug('Connecting to ' + stomp.host + ':' + stomp.port + ' using SSL');
+        stomp.socket = tls.connect(stomp.port, stomp.host, stomp.ssl_options, function() {
+            log.debug('SSL connection complete');
+            if (!stomp.socket.authorized) {
+                log.error('SSL is not authorized: '+stomp.socket.authorizationError);
+                if (stomp.ssl_validate) {
+                    _disconnect(stomp);
+                    return;
+                }
+            }
+            _setupListeners(stomp);
+        });
     } else {
         log.debug('Connecting to ' + stomp.host + ':' + stomp.port);
         stomp.socket = new net.Socket();
@@ -158,13 +158,15 @@ function _setupListeners(stomp) {
 
     socket.on('error', function(error) {
         log.error(error.stack + 'error name: ' + error.name);
+        stomp.emit("error", error);
     });
 
     socket.on('close', function(error) {
         log.debug('disconnected');
-        if (error)
+        if (error) {
             log.error('Disconnected with error: ' + error);
-        stomp.emit("disconnected");
+        }
+        stomp.emit("disconnected", error);
     });
 
     if (stomp.ssl) {