@Test public void testSourceCounter() throws IOException { runKeepFieldsTest("all"); assertEquals(10, source.getSourceCounter().getEventAcceptedCount()); assertEquals(10, source.getSourceCounter().getEventReceivedCount()); }
@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);  }