From 9e68dd6d10b51f7757a2f1cdfa523310f4f9b22d Mon Sep 17 00:00:00 2001 From: pabloFuente Date: Fri, 18 Mar 2022 14:08:20 +0100 Subject: [PATCH] openvidu-server: reorder KurentoClient event handlers on KmsManager --- .../server/kurento/kms/KmsManager.java | 52 +++++++++---------- 1 file changed, 26 insertions(+), 26 deletions(-) diff --git a/openvidu-server/src/main/java/io/openvidu/server/kurento/kms/KmsManager.java b/openvidu-server/src/main/java/io/openvidu/server/kurento/kms/KmsManager.java index 2c64d4ab..e89c98d5 100644 --- a/openvidu-server/src/main/java/io/openvidu/server/kurento/kms/KmsManager.java +++ b/openvidu-server/src/main/java/io/openvidu/server/kurento/kms/KmsManager.java @@ -175,6 +175,32 @@ public abstract class KmsManager { protected JsonRpcWSConnectionListener generateKurentoConnectionListener(final String kmsId) { return new JsonRpcWSConnectionListener() { + @Override + public void connected() { + final Kms kms = kmss.get(kmsId); + log.info("Kurento Client \"connected\" event for KMS {} [{}]", kms.getUri(), + kms.getKurentoClient().toString()); + // TODO: This should be done here, not after KurentoClient#create method + // returns, but it seems that this event is never triggered + // kms.setKurentoClientConnected(true); + // kms.setTimeOfKurentoClientConnection(System.currentTimeMillis()); + } + + @Override + public void connectionFailed() { + final Kms kms = kmss.get(kmsId); + log.error("Kurento Client \"connectionFailed\" event for KMS {} [{}]", kms.getUri(), + kms.getKurentoClient().toString()); + kms.setKurentoClientConnected(false); + } + + @Override + public void reconnecting() { + final Kms kms = kmss.get(kmsId); + log.info("Kurento Client \"reconnecting\" event for KMS {} [{}]", kms.getUri(), + kms.getKurentoClient().toString()); + } + @Override public void reconnected(boolean sameServer) { final Kms kms = kmss.get(kmsId); @@ -318,32 +344,6 @@ public abstract class KmsManager { kurentoClientReconnectTimer.updateTimer(); } - @Override - public void connectionFailed() { - final Kms kms = kmss.get(kmsId); - log.error("Kurento Client \"connectionFailed\" event for KMS {} [{}]", kms.getUri(), - kms.getKurentoClient().toString()); - kms.setKurentoClientConnected(false); - } - - @Override - public void connected() { - final Kms kms = kmss.get(kmsId); - log.info("Kurento Client \"connected\" event for KMS {} [{}]", kms.getUri(), - kms.getKurentoClient().toString()); - // TODO: This should be done here, not after KurentoClient#create method - // returns, but it seems that this event is never triggered - // kms.setKurentoClientConnected(true); - // kms.setTimeOfKurentoClientConnection(System.currentTimeMillis()); - } - - @Override - public void reconnecting() { - final Kms kms = kmss.get(kmsId); - log.info("Kurento Client \"reconnecting\" event for KMS {} [{}]", kms.getUri(), - kms.getKurentoClient().toString()); - } - }; }