diff --git a/beat/core/agent.py b/beat/core/agent.py
index c6bce880d73a13dd4328e51e19816258e92e5bdd..152a9e14b50d35d2cd85f700e89506ef4e107ac2 100755
--- a/beat/core/agent.py
+++ b/beat/core/agent.py
@@ -59,7 +59,7 @@ class Server(MessageHandler):
     self.socket = self.context.socket(zmq.PAIR)
 
     self.address = 'tcp://' + host_address
-    port = self.socket.bind_to_random_port(self.address)
+    port = self.socket.bind_to_random_port(self.address, min_port=50000)
     self.address += ':%d' % port
     logger.debug("zmq server bound to `%s'", self.address)
 
diff --git a/beat/core/test/test_dbexecution.py b/beat/core/test/test_dbexecution.py
old mode 100644
new mode 100755
index ff5c81c9b8bbfbf2eab70b5dfa23834a94d83687..a0d287027f47bd1d8f7bd5976a2b03d99873a92d
--- a/beat/core/test/test_dbexecution.py
+++ b/beat/core/test/test_dbexecution.py
@@ -102,7 +102,7 @@ class HostSide(object):
     # 0MQ server
     self.socket = zmq_context.socket(zmq.PAIR)
     self.address = 'tcp://127.0.0.1'
-    port = self.socket.bind_to_random_port(self.address)
+    port = self.socket.bind_to_random_port(self.address, min_port=50000)
     self.address += ':%d' % port
 
     database = Database(prefix, 'integers_db/1')
diff --git a/beat/core/test/test_message_handler.py b/beat/core/test/test_message_handler.py
old mode 100644
new mode 100755
index 6939476909dc43bede17938bc617a18086ef44aa..e5092fae9edde476053f0a41f32a160feb78fbae
--- a/beat/core/test/test_message_handler.py
+++ b/beat/core/test/test_message_handler.py
@@ -100,7 +100,7 @@ class TestMessageHandler(unittest.TestCase):
     self.server_context = zmq.Context()
     server_socket = self.server_context.socket(zmq.PAIR)
     address = 'tcp://127.0.0.1'
-    port = server_socket.bind_to_random_port(address)
+    port = server_socket.bind_to_random_port(address, min_port=50000)
     address += ':%d' % port
 
     self.message_handler = MessageHandler(self.input_list, self.server_context, server_socket)
@@ -190,7 +190,7 @@ class TestMessageHandlerErrorHandling(unittest.TestCase):
     self.server_context = zmq.Context()
     server_socket = self.server_context.socket(zmq.PAIR)
     address = 'tcp://127.0.0.1'
-    port = server_socket.bind_to_random_port(address)
+    port = server_socket.bind_to_random_port(address, min_port=50000)
     address += ':%d' % port
 
     self.message_handler = MessageHandler(self.input_list, self.server_context, server_socket)