@Test public void testSourceCounterEventFail() throws Exception { init("true"); errorCounterCommon(new RuntimeException("dummy")); for (int i = 0; i < 10 && source.getSourceCounter().getEventReadFail() == 0; i++) { Thread.sleep(100); } assertEquals(1, source.getSourceCounter().getEventReadFail()); }
@VisibleForTesting SourceCounter getSourceCounter() { return sourceCounter; }
SyslogTcpSource extends SslContextAwareAbstractSource implements EventDrivenSource, Configurable { @VisibleForTesting SourceCounter getSourceCounter() { return sourceCounter; } }
SyslogTcpSource extends SslContextAwareAbstractSource implements EventDrivenSource, Configurable { @VisibleForTesting SourceCounter getSourceCounter() { return sourceCounter; }  }
SyslogTcpSource extends SslContextAwareAbstractSource implements EventDrivenSource, Configurable { @VisibleForTesting SourceCounter getSourceCounter() { return sourceCounter; }  @Override void start(); @Override void stop(); @Override void configure(Context context); }
SyslogTcpSource extends SslContextAwareAbstractSource implements EventDrivenSource, Configurable { @VisibleForTesting SourceCounter getSourceCounter() { return sourceCounter; }  @Override void start(); @Override void stop(); @Override void configure(Context context);  }