StatefulServer server = this.listOfServers.get(serverIndex);
if (server.hasFreeSession()) {
server.addSession(subscription);
subscription.setServer(server);
try {
server.subscribe(msgToForward, callback, timeoutMillis);
} catch (Exception e) {
server.removeSession(subscription);
throw e;
}
return;