ambiser
/
openvidu
mirror of https://github.com/OpenVidu/openvidu.git
8
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

openvidu-server: removed "sendMediaNodeAddedEvent" parameter

pull/494/head
pabloFuente 2020-05-29 21:32:50 +02:00
parent cc0479deb3
commit d1aa03354e
3 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
openvidu-server/src/main/java/io/openvidu/server/kurento/kms/FixedOneKmsManager.java
View File

@ -32,8 +32,7 @@ import io.openvidu.server.core.IdentifierPrefixes;
public class FixedOneKmsManager extends KmsManager { public class FixedOneKmsManager extends KmsManager {
@Override @Override
public List<Kms> initializeKurentoClients(List<KmsProperties> kmsProperties, boolean disconnectUponFailure, public List<Kms> initializeKurentoClients(List<KmsProperties> kmsProperties, boolean disconnectUponFailure) throws Exception {
boolean sendMediaNodeAddedEvent) throws Exception {
KmsProperties firstProps = kmsProperties.get(0); KmsProperties firstProps = kmsProperties.get(0);
KurentoClient kClient = null; KurentoClient kClient = null;
Kms kms = new Kms(firstProps, loadManager); Kms kms = new Kms(firstProps, loadManager);
@ -66,7 +65,7 @@ public class FixedOneKmsManager extends KmsManager {
+ RandomStringUtils.randomAlphanumeric(7); + RandomStringUtils.randomAlphanumeric(7);
kmsProps.add(new KmsProperties(kmsId, kmsUri)); kmsProps.add(new KmsProperties(kmsId, kmsUri));
} }
this.initializeKurentoClients(kmsProps, true, false); this.initializeKurentoClients(kmsProps, true);
} catch (Exception e) { } catch (Exception e) {
// Some KMS wasn't reachable // Some KMS wasn't reachable
log.error("Shutting down OpenVidu Server"); log.error("Shutting down OpenVidu Server");

4
openvidu-server/src/main/java/io/openvidu/server/kurento/kms/KmsManager.java
View File

@ -291,8 +291,8 @@ public abstract class KmsManager {
}; };
} }
public abstract List<Kms> initializeKurentoClients(List<KmsProperties> kmsProperties, boolean disconnectUponFailure, public abstract List<Kms> initializeKurentoClients(List<KmsProperties> kmsProperties, boolean disconnectUponFailure)
boolean sendMediaNodeAddedEvent) throws Exception; throws Exception;
public LoadManager getLoadManager() { public LoadManager getLoadManager() {
return this.loadManager; return this.loadManager;

2
openvidu-server/src/test/java/io/openvidu/server/test/integration/config/IntegrationTestConfiguration.java
View File

@ -58,7 +58,7 @@ public class IntegrationTestConfiguration {
successfullyConnectedKmss.add(kms); successfullyConnectedKmss.add(kms);
} }
return successfullyConnectedKmss; return successfullyConnectedKmss;
}).when(spy).initializeKurentoClients(any(List.class), any(Boolean.class), any(Boolean.class)); }).when(spy).initializeKurentoClients(any(List.class), any(Boolean.class));
return spy; return spy;
} }