diff --git a/x2gobroker/brokers/base_broker.py b/x2gobroker/x2gobroker/brokers/base_broker.py

index 3de1426..297f6ee 100644

--- a/x2gobroker/brokers/base_broker.py

+++ b/x2gobroker/brokers/base_broker.py

@@ -1381,15 +1381,26 @@ class X2GoBroker(object):

         server_port = profile['sshport']

         # try to retrieve a remote broker agent

-        remote_agent = self.get_remote_agent(profile_id)

+        remote_agents = self.get_all_remote_agents(profile_id)

+        print(remote_agents)

+        remote_agent = {}

         # check for already running sessions for the given user (if any is given)

         session_list = []

-        if remote_agent and username:

-            try:

-                success, session_list = x2gobroker.agent.list_sessions(username=username, remote_agent=remote_agent)

-            except x2gobroker.x2gobroker_exceptions.X2GoBrokerAgentException:

-                session_list = []

+        if remote_agents and username:

+            for agent in remote_agents:

+                try:

+                    _, session_list_temp = x2gobroker.agent.list_sessions(username=username, remote_agent=agent)

+                    print(session_list_temp)

+                    if len(session_list_temp) > 0:

+                        # session list is not empty

+                        session_list.extend(session_list_temp)

+                        remote_agent = agent

+                except x2gobroker.x2gobroker_exceptions.X2GoBrokerAgentException:

+                    session_list_temp = []

+                    remote_agents.remove(agent)

+        if len(session_list) == 0 and len(remote_agents) > 0:

+            remote_agent = random.choice(remote_agents)

         session_info = None