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 <solomax...@gmail.com>
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
solo...@apache.org.

Reply via email to