import org.red5.logging.Red5LoggerFactory;
import org.slf4j.Logger;
public class ConnectionManager  {
private static Logger log = Red5LoggerFactory.getLogger(ConnectionManager.class, "bigbluebutton");
private static final String EVENT_NAME = "Event-Name";
<BUG>private static final int CONNECT_THREAD = 1;
private static final ScheduledExecutorService connExec = Executors.newScheduledThreadPool(CONNECT_THREAD);
</BUG>
private ManagerConnection manager;
<BUG>private volatile boolean attemptConnect = false;
private volatile boolean subscribed = false;
private ConferenceEventListener conferenceEventListener;
private void connect() {</BUG>
try {

import org.red5.logging.Red5LoggerFactory;
import org.slf4j.Logger;
public class ConnectionManager  {
private static Logger log = Red5LoggerFactory.getLogger(ConnectionManager.class, "bigbluebutton");
private static final String EVENT_NAME = "Event-Name";
private static final ScheduledExecutorService connExec = Executors.newSingleThreadScheduledExecutor();
private ManagerConnection manager;
private ScheduledFuture<ConnectThread> connectTask;
private volatile boolean subscribed = false;
private ConferenceEventListener conferenceEventListener;
private ESLEventListener eslEventListener;
private void connect() {
try {
