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 <[email protected]>
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();
}