From 3a38ed9e86aaca7c29ea10ff8f3ebe8ec24e3ad9 Mon Sep 17 00:00:00 2001
From: Jan Waller <jwa@informatik.uni-kiel.de>
Date: Tue, 24 Jun 2014 13:37:27 +0200
Subject: [PATCH] improve output of TCPCountingReader Test also fix shutdown of
said test
---
frameworks/Kieker/src/kieker/tcp/TestExperiment1.java | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
diff --git a/frameworks/Kieker/src/kieker/tcp/TestExperiment1.java b/frameworks/Kieker/src/kieker/tcp/TestExperiment1.java
index c4f0ff4..335259e 100644
--- a/frameworks/Kieker/src/kieker/tcp/TestExperiment1.java
+++ b/frameworks/Kieker/src/kieker/tcp/TestExperiment1.java
@@ -109,19 +109,20 @@ final class TCPCountingReader extends AbstractReaderPlugin {
private final ILookup<String> stringRegistry = new Lookup<String>();
final AtomicInteger counter = new AtomicInteger(0);
+ final ScheduledExecutorService executorService;
public TCPCountingReader(final Configuration configuration, final IProjectContext projectContext) {
super(configuration, projectContext);
this.port1 = this.configuration.getIntProperty(CONFIG_PROPERTY_NAME_PORT1);
this.port2 = this.configuration.getIntProperty(CONFIG_PROPERTY_NAME_PORT2);
+ this.executorService = new ScheduledThreadPoolExecutor(1);
}
@Override
public boolean init() {
- final ScheduledExecutorService executorService = new ScheduledThreadPoolExecutor(1);
- executorService.scheduleAtFixedRate(new Runnable() {
+ this.executorService.scheduleAtFixedRate(new Runnable() {
public void run() {
- LOG.info("Records/s: " + TCPCountingReader.this.counter.getAndSet(0));
+ System.out.println("Records/s: " + TCPCountingReader.this.counter.getAndSet(0));
}
}, 0, 1, TimeUnit.SECONDS);
@@ -196,6 +197,7 @@ final class TCPCountingReader extends AbstractReaderPlugin {
public void terminate(final boolean error) {
LOG.info("Shutdown of TCPReader requested.");
+ this.executorService.shutdown();
}
}
--
GitLab