You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@openmeetings.apache.org by so...@apache.org on 2023/03/31 08:41:13 UTC

[openmeetings] branch master updated: [OPENMEETINGS-2758] deprecated KMS API is dropped

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