diff --git a/openvidu-server/src/main/java/io/openvidu/server/kurento/endpoint/SubscriberEndpoint.java b/openvidu-server/src/main/java/io/openvidu/server/kurento/endpoint/SubscriberEndpoint.java index db6309e4..215e576c 100644 --- a/openvidu-server/src/main/java/io/openvidu/server/kurento/endpoint/SubscriberEndpoint.java +++ b/openvidu-server/src/main/java/io/openvidu/server/kurento/endpoint/SubscriberEndpoint.java @@ -18,7 +18,6 @@ package io.openvidu.server.kurento.endpoint; import java.util.Map.Entry; -import java.util.concurrent.atomic.AtomicBoolean; import org.kurento.client.MediaPipeline; import org.slf4j.Logger; @@ -36,9 +35,8 @@ import io.openvidu.server.kurento.core.KurentoParticipant; * @author Radu Tom Vlad */ 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; @@ -53,19 +51,10 @@ public class SubscriberEndpoint extends MediaEndpoint { String sdpAnswer = processOffer(sdpOffer); gatherCandidates(); publisher.connect(this.getEndpoint()); - setConnectedToPublisher(true); this.publisherStreamId = publisher.getStreamId(); return sdpAnswer; } - public boolean isConnectedToPublisher() { - return connectedToPublisher.get(); - } - - public void setConnectedToPublisher(boolean connectedToPublisher) { - this.connectedToPublisher.set(connectedToPublisher); - } - @Override public JsonObject toJson() { JsonObject json = super.toJson();