@Test public void testLifecycle() throws InterruptedException { bind(); Thread.sleep(1000); stop(); }
@Override public void stop() { server.stop(); serverTransport.close(); try { thriftHandlerThread.join(); } catch (InterruptedException eI) { LOG.warn("stop interrupted", eI); return; } super.stop(); }
ThriftLegacySource extends AbstractSource implements
    EventDrivenSource, Configurable { @Override public void stop() { server.stop(); serverTransport.close(); try { thriftHandlerThread.join(); } catch (InterruptedException eI) { LOG.warn("stop interrupted", eI); return; } super.stop(); } }
ThriftLegacySource extends AbstractSource implements
    EventDrivenSource, Configurable { @Override public void stop() { server.stop(); serverTransport.close(); try { thriftHandlerThread.join(); } catch (InterruptedException eI) { LOG.warn("stop interrupted", eI); return; } super.stop(); } ThriftLegacySource(); }
ThriftLegacySource extends AbstractSource implements
    EventDrivenSource, Configurable { @Override public void stop() { server.stop(); serverTransport.close(); try { thriftHandlerThread.join(); } catch (InterruptedException eI) { LOG.warn("stop interrupted", eI); return; } super.stop(); } ThriftLegacySource(); @Override void configure(Context context); @SuppressWarnings("deprecation") @Override void start(); @Override void stop(); }
ThriftLegacySource extends AbstractSource implements
    EventDrivenSource, Configurable { @Override public void stop() { server.stop(); serverTransport.close(); try { thriftHandlerThread.join(); } catch (InterruptedException eI) { LOG.warn("stop interrupted", eI); return; } super.stop(); } ThriftLegacySource(); @Override void configure(Context context); @SuppressWarnings("deprecation") @Override void start(); @Override void stop();  }