diff --git a/src/main/java/teetime/framework/AbstractStage.java b/src/main/java/teetime/framework/AbstractStage.java index 4b89d127d93ba57d117dc4e18f3c46d04683b372..af656894919486fc8f264f1fbd503bc4957b4ef5 100644 --- a/src/main/java/teetime/framework/AbstractStage.java +++ b/src/main/java/teetime/framework/AbstractStage.java @@ -113,7 +113,7 @@ public abstract class AbstractStage extends Stage { this.connectUnconnectedOutputPorts(); currentState = StageState.STARTED; - logger.debug("Started."); + logger.trace("Started."); } @SuppressWarnings("PMD.DataflowAnomalyAnalysis") @@ -132,6 +132,7 @@ public abstract class AbstractStage extends Stage { @Override public void onTerminating() throws Exception { currentState = StageState.TERMINATED; + logger.trace("Terminated."); } /** diff --git a/src/main/java/teetime/stage/string/Tokenizer.java b/src/main/java/teetime/stage/string/Tokenizer.java index f09b16de53a7cabae85ceb5e7287d52cffe863aa..7e451b5b55e321e503f97355fc68622294870bcf 100644 --- a/src/main/java/teetime/stage/string/Tokenizer.java +++ b/src/main/java/teetime/stage/string/Tokenizer.java @@ -15,8 +15,6 @@ */ package teetime.stage.string; -import java.util.StringTokenizer; - import teetime.framework.AbstractConsumerStage; import teetime.framework.OutputPort; @@ -31,9 +29,9 @@ public final class Tokenizer extends AbstractConsumerStage<String> { @Override protected void execute(final String element) { - StringTokenizer st = new StringTokenizer(element, this.regex); - while (st.hasMoreTokens()) { - outputPort.send(st.nextToken()); + String[] tokens = element.split(regex); + for (String token : tokens) { + outputPort.send(token); } }