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();
        }

Reply via email to