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 317638fe..dc8acb6d 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 @@ -35,6 +35,7 @@ import javax.annotation.PreDestroy; import org.apache.commons.lang3.RandomStringUtils; import org.kurento.client.GenericMediaElement; +import org.kurento.client.GenericMediaEvent; import org.kurento.client.IceCandidate; import org.kurento.client.ListenerSubscription; import org.kurento.client.PassThrough; @@ -1355,7 +1356,7 @@ public class KurentoSessionManager extends SessionManager { sessionEventsHandler.onFilterEventDispatched(sessionId, uniqueSessionId, connectionId, streamId, filterType, event, kParticipant.getSession().getParticipants(), kParticipant.getPublisher().getPartipantsListentingToFilterEvent(eventType)); - }); + }, GenericMediaEvent.class); pub.storeListener(eventType, listener); } catch (Exception e) { log.error("Request to addFilterEventListener to stream {} gone wrong. Error: {}", streamId, diff --git a/openvidu-server/src/main/java/io/openvidu/server/kurento/endpoint/PublisherEndpoint.java b/openvidu-server/src/main/java/io/openvidu/server/kurento/endpoint/PublisherEndpoint.java index d2652417..26ec0054 100644 --- a/openvidu-server/src/main/java/io/openvidu/server/kurento/endpoint/PublisherEndpoint.java +++ b/openvidu-server/src/main/java/io/openvidu/server/kurento/endpoint/PublisherEndpoint.java @@ -353,7 +353,7 @@ public class PublisherEndpoint extends MediaEndpoint { public JsonElement execMethod(String method, JsonObject params) throws OpenViduException { Props props = new JsonUtils().fromJsonObjectToProps(params); - return (JsonElement) ((GenericMediaElement) this.filter).invoke(method, props); + return (JsonElement) ((GenericMediaElement) this.filter).invoke(method, props, JsonElement.class); } public synchronized void mute(TrackType muteType) {