Revert "Propagate errors from backend connection (#81)" (#86)

This reverts commit 96207bd.

Author: mher

celery.js

@@ -211,15 +211,18 @@ function Client(conf) {
             self.emit('message', msg);
         });
     } else if (self.conf.backend_type === 'amqp') {
-        self.backend = amqp.createConnection(self.conf.BROKER_OPTIONS, {
+        self.backend = amqp.createConnection({
+            url: self.conf.BROKER_URL,
+            heartbeat: 580
+        }, {
             defaultExchangeName: self.conf.DEFAULT_EXCHANGE
         });
+    } else if (self.conf.backend_type === self.conf.broker_type) {
+        if (self.conf.backend_type === 'amqp') {
+          self.backend = self.broker;
+        }
     }
 
-    self.backend.on('error', function(err) {
-        self.emit('error', err);
-    });
-
     // backend ready...
     self.backend.on('ready', function() {
         debug('Connecting to broker...');