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

openvidu-server: remove unused property of SubscriberEndpoint

pull/621/head
pabloFuente 2021-03-11 17:24:01 +01:00
parent 5b3dca2907
commit 6d5bca0762
1 changed files with 1 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
openvidu-server/src/main/java/io/openvidu/server/kurento/endpoint/SubscriberEndpoint.java
View File

@ -18,7 +18,6 @@
package io.openvidu.server.kurento.endpoint; package io.openvidu.server.kurento.endpoint;
import java.util.Map.Entry; import java.util.Map.Entry;
import java.util.concurrent.atomic.AtomicBoolean;
import org.kurento.client.MediaPipeline; import org.kurento.client.MediaPipeline;
import org.slf4j.Logger; import org.slf4j.Logger;
@ -36,9 +35,8 @@ import io.openvidu.server.kurento.core.KurentoParticipant;
* @author <a href="mailto:rvlad@naevatec.com">Radu Tom Vlad</a> * @author <a href="mailto:rvlad@naevatec.com">Radu Tom Vlad</a>
*/ */
public class SubscriberEndpoint extends MediaEndpoint { public class SubscriberEndpoint extends MediaEndpoint {
private final static Logger log = LoggerFactory.getLogger(SubscriberEndpoint.class);
private AtomicBoolean connectedToPublisher = new AtomicBoolean(false); private final static Logger log = LoggerFactory.getLogger(SubscriberEndpoint.class);
private String publisherStreamId; private String publisherStreamId;
@ -53,19 +51,10 @@ public class SubscriberEndpoint extends MediaEndpoint {
String sdpAnswer = processOffer(sdpOffer); String sdpAnswer = processOffer(sdpOffer);
gatherCandidates(); gatherCandidates();
publisher.connect(this.getEndpoint()); publisher.connect(this.getEndpoint());
setConnectedToPublisher(true);
this.publisherStreamId = publisher.getStreamId(); this.publisherStreamId = publisher.getStreamId();
return sdpAnswer; return sdpAnswer;
} }
public boolean isConnectedToPublisher() {
return connectedToPublisher.get();
}
public void setConnectedToPublisher(boolean connectedToPublisher) {
this.connectedToPublisher.set(connectedToPublisher);
}
@Override @Override
public JsonObject toJson() { public JsonObject toJson() {
JsonObject json = super.toJson(); JsonObject json = super.toJson();