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 bc32b20 [OPENMEETINGS-1649] stubs for flow events are added
bc32b20 is described below
commit bc32b201e5c27e457569c9142da97796a700e607
Author: Maxim Solodovnik <[email protected]>
AuthorDate: Sun Mar 11 23:54:28 2018 +0700
[OPENMEETINGS-1649] stubs for flow events are added
---
.../org/apache/openmeetings/core/remote/KUser.java | 22 +++++++++++++++++++---
1 file changed, 19 insertions(+), 3 deletions(-)
diff --git
a/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/KUser.java
b/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/KUser.java
index e2bbb2a..fd1031b 100644
---
a/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/KUser.java
+++
b/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/KUser.java
@@ -23,10 +23,12 @@ import java.io.Closeable;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
+import org.kurento.client.ConnectionStateChangedEvent;
import org.kurento.client.Continuation;
import org.kurento.client.EventListener;
import org.kurento.client.IceCandidate;
import org.kurento.client.IceCandidateFoundEvent;
+import org.kurento.client.MediaFlowOutStateChangeEvent;
import org.kurento.client.MediaPipeline;
import org.kurento.client.WebRtcEndpoint;
import org.kurento.jsonrpc.JsonUtils;
@@ -53,10 +55,11 @@ public class KUser implements Closeable {
this.pipeline = pipeline;
this.uid = uid;
this.roomId = roomId;
- this.outgoingMedia = new
WebRtcEndpoint.Builder(pipeline).build();
-
- this.outgoingMedia.addIceCandidateFoundListener(new
EventListener<IceCandidateFoundEvent>() {
+ //TODO Min/MaxVideoSendBandwidth
+ //TODO Min/Max Audio/Video RecvBandwidth
+ outgoingMedia = new WebRtcEndpoint.Builder(pipeline).build();
+ outgoingMedia.addIceCandidateFoundListener(new
EventListener<IceCandidateFoundEvent>() {
@Override
public void onEvent(IceCandidateFoundEvent event) {
JSONObject response = newKurentoMsg();
@@ -66,6 +69,19 @@ public class KUser implements Closeable {
h.sendClient(uid, response);
}
});
+ //TODO add logic here
+ outgoingMedia.addConnectionStateChangedListener(new
EventListener<ConnectionStateChangedEvent>() {
+ @Override
+ public void onEvent(ConnectionStateChangedEvent event) {
+ log.warn("StateChanged {} -> {}",
event.getOldState(), event.getNewState());
+ }
+ });
+ outgoingMedia.addMediaFlowOutStateChangeListener(new
EventListener<MediaFlowOutStateChangeEvent>() {
+ @Override
+ public void onEvent(MediaFlowOutStateChangeEvent event)
{
+ log.warn("MediaFlowOutStateChange {}",
event.getState());
+ }
+ });
}
public WebRtcEndpoint getOutgoingWebRtcPeer() {
--
To stop receiving notification emails like this one, please contact
[email protected].
