diff --git a/openvidu-server/src/main/java/io/openvidu/server/core/SessionManager.java b/openvidu-server/src/main/java/io/openvidu/server/core/SessionManager.java index c986678f..eb33cb8c 100644 --- a/openvidu-server/src/main/java/io/openvidu/server/core/SessionManager.java +++ b/openvidu-server/src/main/java/io/openvidu/server/core/SessionManager.java @@ -303,8 +303,10 @@ public abstract class SessionManager { } public Session storeSessionNotActive(String sessionId, SessionProperties sessionProperties) { - Session sessionNotActive = new Session(sessionId, sessionProperties, openviduConfig, recordingManager); - return this.storeSessionNotActive(sessionNotActive); + Session sessionNotActive = this + .storeSessionNotActive(new Session(sessionId, sessionProperties, openviduConfig, recordingManager)); + sessionEventsHandler.onSessionCreated(sessionNotActive); + return sessionNotActive; } public Session storeSessionNotActive(Session sessionNotActive) { diff --git a/openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSessionManager.java b/openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSessionManager.java index fd90166f..317638fe 100644 --- a/openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSessionManager.java +++ b/openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSessionManager.java @@ -777,7 +777,6 @@ public class KurentoSessionManager extends SessionManager { log.info("No session '{}' exists yet. Created one on KMS '{}' with ip '{}'", session.getSessionId(), kms.getId(), kms.getIp()); - sessionEventsHandler.onSessionCreated(session); return session; } diff --git a/openvidu-server/src/main/java/io/openvidu/server/rest/SessionRestController.java b/openvidu-server/src/main/java/io/openvidu/server/rest/SessionRestController.java index 7499af49..1574514f 100644 --- a/openvidu-server/src/main/java/io/openvidu/server/rest/SessionRestController.java +++ b/openvidu-server/src/main/java/io/openvidu/server/rest/SessionRestController.java @@ -121,7 +121,7 @@ public class SessionRestController { } Session sessionNotActive = sessionManager.storeSessionNotActive(sessionId, sessionProperties); - log.info("New session {} initialized {}", sessionId, this.sessionManager.getSessionsWithNotActive().stream() + log.info("New session {} created {}", sessionId, this.sessionManager.getSessionsWithNotActive().stream() .map(Session::getSessionId).collect(Collectors.toList()).toString()); return new ResponseEntity<>(sessionNotActive.toJson(false, false).toString(), RestUtils.getResponseHeaders(),