diff --git a/bus/rabbitmq/bus.js b/bus/rabbitmq/bus.js
index ccf318a..d3dc4fa 100644
--- a/bus/rabbitmq/bus.js
+++ b/bus/rabbitmq/bus.js
@@ -111,6 +111,8 @@ function RabbitMQBus (options, implOpts) {
       });
     }
 
+    return self.connection;
+
   }).catch(function (err) {
     self.log('error connecting to rabbitmq: %s', err);
     self.emit('error', err);