openvidu-server: updated KurentoClient generic methods usage

pull/634/head
pabloFuente 2021-06-21 11:14:53 +02:00
parent deb01720f3
commit 35238a3390
2 changed files with 3 additions and 2 deletions

View File

@ -35,6 +35,7 @@ import javax.annotation.PreDestroy;
import org.apache.commons.lang3.RandomStringUtils; import org.apache.commons.lang3.RandomStringUtils;
import org.kurento.client.GenericMediaElement; import org.kurento.client.GenericMediaElement;
import org.kurento.client.GenericMediaEvent;
import org.kurento.client.IceCandidate; import org.kurento.client.IceCandidate;
import org.kurento.client.ListenerSubscription; import org.kurento.client.ListenerSubscription;
import org.kurento.client.PassThrough; import org.kurento.client.PassThrough;
@ -1355,7 +1356,7 @@ public class KurentoSessionManager extends SessionManager {
sessionEventsHandler.onFilterEventDispatched(sessionId, uniqueSessionId, connectionId, streamId, sessionEventsHandler.onFilterEventDispatched(sessionId, uniqueSessionId, connectionId, streamId,
filterType, event, kParticipant.getSession().getParticipants(), filterType, event, kParticipant.getSession().getParticipants(),
kParticipant.getPublisher().getPartipantsListentingToFilterEvent(eventType)); kParticipant.getPublisher().getPartipantsListentingToFilterEvent(eventType));
}); }, GenericMediaEvent.class);
pub.storeListener(eventType, listener); pub.storeListener(eventType, listener);
} catch (Exception e) { } catch (Exception e) {
log.error("Request to addFilterEventListener to stream {} gone wrong. Error: {}", streamId, log.error("Request to addFilterEventListener to stream {} gone wrong. Error: {}", streamId,

View File

@ -353,7 +353,7 @@ public class PublisherEndpoint extends MediaEndpoint {
public JsonElement execMethod(String method, JsonObject params) throws OpenViduException { public JsonElement execMethod(String method, JsonObject params) throws OpenViduException {
Props props = new JsonUtils().fromJsonObjectToProps(params); 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) { public synchronized void mute(TrackType muteType) {