@Test public void testApp(){ sut.start(); }
public void start() { try { initiator.start(); logger.info("The Client is started"); shutdown_latch.await(); } catch (RuntimeError | ConfigError e) { throw new FixException(e); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } }
ClientMessageConnector { public void start() { try { initiator.start(); logger.info("The Client is started"); shutdown_latch.await(); } catch (RuntimeError | ConfigError e) { throw new FixException(e); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } }
ClientMessageConnector { public void start() { try { initiator.start(); logger.info("The Client is started"); shutdown_latch.await(); } catch (RuntimeError | ConfigError e) { throw new FixException(e); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } ClientMessageConnector(); }
ClientMessageConnector { public void start() { try { initiator.start(); logger.info("The Client is started"); shutdown_latch.await(); } catch (RuntimeError | ConfigError e) { throw new FixException(e); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } ClientMessageConnector(); void start(); void sendLogoff(); void stop(); }
ClientMessageConnector { public void start() { try { initiator.start(); logger.info("The Client is started"); shutdown_latch.await(); } catch (RuntimeError | ConfigError e) { throw new FixException(e); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } ClientMessageConnector(); void start(); void sendLogoff(); void stop(); static final Logger logger; static final String CONFIG_FILE; final CountDownLatch shutdown_latch; }