diff --git a/openvidu-server/src/main/java/io/openvidu/server/config/OpenviduConfig.java b/openvidu-server/src/main/java/io/openvidu/server/config/OpenviduConfig.java index 13173325..fd609f87 100644 --- a/openvidu-server/src/main/java/io/openvidu/server/config/OpenviduConfig.java +++ b/openvidu-server/src/main/java/io/openvidu/server/config/OpenviduConfig.java @@ -772,6 +772,20 @@ public class OpenviduConfig { } } + protected Double asNonNegativeDouble(String property) { + try { + Double doubleValue = Double.parseDouble(getValue(property)); + + if (doubleValue < 0) { + addError(property, "Is not a non negative double"); + } + return doubleValue; + } catch (NumberFormatException e) { + addError(property, "Is not a non negative doubleValue"); + return 0.0; + } + } + /* * This method checks all types of Internet addresses (IPv4, IPv6 and Domains) */ diff --git a/openvidu-server/src/main/java/io/openvidu/server/core/SessionEventsHandler.java b/openvidu-server/src/main/java/io/openvidu/server/core/SessionEventsHandler.java index e217cff4..982d96f5 100644 --- a/openvidu-server/src/main/java/io/openvidu/server/core/SessionEventsHandler.java +++ b/openvidu-server/src/main/java/io/openvidu/server/core/SessionEventsHandler.java @@ -311,6 +311,10 @@ public class SessionEventsHandler { rpcNotificationService.sendResponse(participant.getParticipantPrivateId(), transactionId, new JsonObject()); } + public void onNetworkQualityChanged(Participant participant, JsonObject params ) { + rpcNotificationService.sendNotification(participant.getParticipantPrivateId(), ProtocolElements.NETWORKQUALITYCHANGED_METHOD, params); + } + public void onSendMessage(Participant participant, JsonObject message, Set participants, Integer transactionId, OpenViduException error) {