ambiser
/
openvidu
mirror of https://github.com/OpenVidu/openvidu.git
8
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

openvidu-server: Added publishedAt property to participant

pull/553/head
csantosm 2020-10-15 16:46:53 +02:00
parent 4c93cb7a7f
commit e20db3f503
2 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
openvidu-server/src/main/java/io/openvidu/server/core/Participant.java
View File

@ -63,6 +63,7 @@ public class Participant {
protected Integer videoHeight = 0; protected Integer videoHeight = 0;
protected Boolean videoActive = false; protected Boolean videoActive = false;
protected Boolean audioActive = false; protected Boolean audioActive = false;
protected Long publishedAt = null; // Timestamp when this participant was published
protected boolean streaming = false; protected boolean streaming = false;
protected volatile boolean closed = false; protected volatile boolean closed = false;
@ -196,6 +197,14 @@ public class Participant {
return audioActive; return audioActive;
} }
public void setPublishedAt(Long publishedAt) {
this.publishedAt = publishedAt;
}
public Long getPublishedAt() {
return publishedAt;
}
public void setAudioActive(Boolean audioActive) { public void setAudioActive(Boolean audioActive) {
this.audioActive = audioActive; this.audioActive = audioActive;
} }

2
openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSessionManager.java
View File

@ -21,6 +21,7 @@ import java.io.IOException;
import java.net.InetAddress; import java.net.InetAddress;
import java.net.MalformedURLException; import java.net.MalformedURLException;
import java.net.URL; import java.net.URL;
import java.sql.Timestamp;
import java.util.Arrays; import java.util.Arrays;
import java.util.Collections; import java.util.Collections;
import java.util.HashSet; import java.util.HashSet;
@ -467,6 +468,7 @@ public class KurentoSessionManager extends SessionManager {
} }
participant.setPublishedAt(new Timestamp(System.currentTimeMillis()).getTime());
kSession.newPublisher(participant); kSession.newPublisher(participant);
participants = kParticipant.getSession().getParticipants(); participants = kParticipant.getSession().getParticipants();