Connecting to backup source multithreading

[zumb001]

Hey, thank you for your reply. Yeah, the thread is calling a blocking command because I have a timeout mechanism that gives the new client only a certain amount of time to reconnect. So its like::

ClientListener:

case "DISCONNECTED":
    clientHandler.switchConnection()

ClientHandler:

switchConnection():
// configure client with new connections
client.add(new ClientListener(CountDownLatch) )------> Upon receiving status "CONNECTED: WS-STREAMING" it counts down the latch
client.connect()
if (!countDownLatch.wait(timeoutTime)) {
    // throw error, couldn't connect
}

[Alessandro Carioni]

Since the Lightstreamer Client API is asynchronous, blocking its threads can have unexpected results.
However you can set a timeout by using a java.util.Timer (or equivalent asynchronous mechanism).
For example:

var client = new LightstreamerClient(...)
Timer timer = new Timer();
timer.schedule(() -> {
  if (!client.getStatus().startsWith("CONNECTED")) {
    client.disconnect();
  }
}, TIMEOUT);
client.connect();

[zumb001]

Right, ok. Well thank you for your help. I think at the end of the day I can't call my switch connection startup method directly from the listener because even if I do as you suggested with a timer then the server I am connecting to uses a chain of subscriptions (i.e. one subscription relies on processing the snapshot from the previous one) so I will need the dedicated listener thread to be available while going through the subscription process to receive the updates.

Thanks!