public void connect() throws IOException { protocolSession = protocolConnector.connect(getNextSocketAddress(), protocolProvider); reconnectFuture = executor.scheduleWithFixedDelay(new ReconnectTask(), reconnectInterval, reconnectInterval, TimeUnit.SECONDS);
public synchronized void connect() { lastReconnectAttemptTime = SystemTime.currentTimeMillis(); try { protocolSession = protocolConnector.connect(getNextSocketAddress(), protocolProvider); } catch (Throwable e) { quickfixSession.getLog().onEvent("Connection failed: " + e.getMessage()); }
    public void connect() throws IOException {        protocolSession = protocolConnector.connect(getNextSocketAddress(), protocolProvider);        reconnectFuture = executor.scheduleWithFixedDelay(new ReconnectTask(), reconnectInterval,                reconnectInterval, TimeUnit.SECONDS);    }