diff --git a/portas/portas/api/v1/sessions.py b/portas/portas/api/v1/sessions.py
index 77734a8..cf3243a 100644
--- a/portas/portas/api/v1/sessions.py
+++ b/portas/portas/api/v1/sessions.py
@@ -17,7 +17,7 @@ log = logging.getLogger(__name__)
 class Controller(object):
     def __init__(self):
         self.write_lock = Semaphore(1)
-        connection = amqp.Connection(rabbitmq.host, virtual_host=rabbitmq.virtual_host,
+        connection = amqp.Connection('{0}:{1}'.format(rabbitmq.host, rabbitmq.port), virtual_host=rabbitmq.virtual_host,
                                      userid=rabbitmq.userid, password=rabbitmq.password,
                                      ssl=rabbitmq.use_ssl, insist=True)
         self.ch = connection.channel()
diff --git a/portas/portas/common/service.py b/portas/portas/common/service.py
index b27774f..f9a13cf 100644
--- a/portas/portas/common/service.py
+++ b/portas/portas/common/service.py
@@ -27,7 +27,7 @@ class TaskResultHandlerService(service.Service):
         super(TaskResultHandlerService, self).stop()
 
     def _handle_results(self):
-        connection = amqp.Connection(rabbitmq.host, virtual_host=rabbitmq.virtual_host,
+        connection = amqp.Connection('{0}:{1}'.format(rabbitmq.host, rabbitmq.port), virtual_host=rabbitmq.virtual_host,
                                      userid=rabbitmq.userid, password=rabbitmq.password,
                                      ssl=rabbitmq.use_ssl, insist=True)
         ch = connection.channel()