@Test public void testMultiplePorts() throws IOException, ParseException { MultiportSyslogTCPSource source = new MultiportSyslogTCPSource(); Channel channel = new MemoryChannel(); List<Event> channelEvents = new ArrayList<>(); int numPorts = 1000; List<Integer> portList = testNPorts(source, channel, channelEvents, numPorts, null, getSimpleEventSender(), new Context()); processEvents(channelEvents, numPorts, portList); source.stop(); }
@Override public void stop() { logger.info("Stopping {}...", this); acceptor.unbind(); acceptor.dispose(); sourceCounter.stop(); super.stop(); logger.info("{} stopped. Metrics: {}", this, sourceCounter); }
MultiportSyslogTCPSource extends SslContextAwareAbstractSource implements
        EventDrivenSource, Configurable, BatchSizeSupported { @Override public void stop() { logger.info("Stopping {}...", this); acceptor.unbind(); acceptor.dispose(); sourceCounter.stop(); super.stop(); logger.info("{} stopped. Metrics: {}", this, sourceCounter); } }
MultiportSyslogTCPSource extends SslContextAwareAbstractSource implements
        EventDrivenSource, Configurable, BatchSizeSupported { @Override public void stop() { logger.info("Stopping {}...", this); acceptor.unbind(); acceptor.dispose(); sourceCounter.stop(); super.stop(); logger.info("{} stopped. Metrics: {}", this, sourceCounter); } MultiportSyslogTCPSource(); }
MultiportSyslogTCPSource extends SslContextAwareAbstractSource implements
        EventDrivenSource, Configurable, BatchSizeSupported { @Override public void stop() { logger.info("Stopping {}...", this); acceptor.unbind(); acceptor.dispose(); sourceCounter.stop(); super.stop(); logger.info("{} stopped. Metrics: {}", this, sourceCounter); } MultiportSyslogTCPSource(); @Override void configure(Context context); @Override void start(); @Override void stop(); @Override String toString(); @Override long getBatchSize(); }
MultiportSyslogTCPSource extends SslContextAwareAbstractSource implements
        EventDrivenSource, Configurable, BatchSizeSupported { @Override public void stop() { logger.info("Stopping {}...", this); acceptor.unbind(); acceptor.dispose(); sourceCounter.stop(); super.stop(); logger.info("{} stopped. Metrics: {}", this, sourceCounter); } MultiportSyslogTCPSource(); @Override void configure(Context context); @Override void start(); @Override void stop(); @Override String toString(); @Override long getBatchSize(); static final Logger logger; }