This is an automated email from the ASF dual-hosted git repository. solomax pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/openmeetings.git
The following commit(s) were added to refs/heads/master by this push: new afa6bc415 [OPENMEETINGS-2758] deprecated KMS API is dropped afa6bc415 is described below commit afa6bc41564ce2a8163ef5e51d2de8f419db7065 Author: Maxim Solodovnik <solomax...@gmail.com> AuthorDate: Fri Mar 31 15:41:03 2023 +0700 [OPENMEETINGS-2758] deprecated KMS API is dropped --- .../src/main/java/org/apache/openmeetings/mediaserver/KStream.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/openmeetings-mediaserver/src/main/java/org/apache/openmeetings/mediaserver/KStream.java b/openmeetings-mediaserver/src/main/java/org/apache/openmeetings/mediaserver/KStream.java index b6bddfc35..8a6856a59 100644 --- a/openmeetings-mediaserver/src/main/java/org/apache/openmeetings/mediaserver/KStream.java +++ b/openmeetings-mediaserver/src/main/java/org/apache/openmeetings/mediaserver/KStream.java @@ -190,7 +190,7 @@ public class KStream extends AbstractStream implements ISipCallbacks { private void internalStartBroadcast(final StreamDesc sd, final String sdpOffer) { outgoingMedia.addMediaSessionTerminatedListener(evt -> log.warn("Media stream terminated {}", sd)); - flowoutSubscription = outgoingMedia.addMediaFlowOutStateChangeListener(evt -> { + flowoutSubscription = outgoingMedia.addMediaFlowOutStateChangedListener(evt -> { log.info("Media Flow OUT STATE :: {}, mediaType {}, source {}, sid {}, uid {}" , evt.getState(), evt.getMediaType(), evt.getSource(), sid, uid); if (MediaFlowState.NOT_FLOWING == evt.getState() @@ -208,7 +208,7 @@ public class KStream extends AbstractStream implements ISipCallbacks { dropFlowoutFuture(); } }); - outgoingMedia.addMediaFlowInStateChangeListener(evt -> log.warn("Media Flow IN :: {}, {}, {}, sid {}, uid {}" + outgoingMedia.addMediaFlowInStateChangedListener(evt -> log.warn("Media Flow IN :: {}, {}, {}, sid {}, uid {}" , evt.getState(), evt.getMediaType(), evt.getSource(), sid, uid)); if (!sipClient) { addListener(sd.getSid(), sd.getUid(), sdpOffer); @@ -232,7 +232,7 @@ public class KStream extends AbstractStream implements ISipCallbacks { public void broadcastRestarted() { if (outgoingMedia != null && flowoutSubscription != null) { - outgoingMedia.removeMediaFlowOutStateChangeListener(flowoutSubscription); + outgoingMedia.removeMediaFlowOutStateChangedListener(flowoutSubscription); } dropFlowoutFuture(); }