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

openvidu-server: warn instead of error when websocket has been closed by client

pull/648/head
pabloFuente 2021-07-08 15:31:01 +02:00
parent 0d739982a8
commit 432301e565
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
openvidu-server/src/main/java/io/openvidu/server/rpc/RpcNotificationService.java
View File

@ -24,6 +24,7 @@ import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import org.kurento.commons.exception.KurentoException;
import org.kurento.jsonrpc.Session; import org.kurento.jsonrpc.Session;
import org.kurento.jsonrpc.Transaction; import org.kurento.jsonrpc.Transaction;
import org.kurento.jsonrpc.message.Request; import org.kurento.jsonrpc.message.Request;
@ -109,6 +110,15 @@ public class RpcNotificationService {
try { try {
s.sendNotification(method, params); s.sendNotification(method, params);
} catch (KurentoException e) {
if (e.getCause().getMessage()
.contains("been closed and no method (apart from close()) may be called on a closed session")) {
log.warn("Notification '{}' couldn't be sent to participant with privateId {}: {}", method,
participantPrivateId, e.getCause().getMessage());
} else {
log.error("Exception sending notification '{}': {} to participant with private id {}", method, params,
participantPrivateId, e);
}
} catch (Exception e) { } catch (Exception e) {
log.error("Exception sending notification '{}': {} to participant with private id {}", method, params, log.error("Exception sending notification '{}': {} to participant with private id {}", method, params,
participantPrivateId, e); participantPrivateId, e);