removing this because when monitorThread runs broadcastMonitor doesn't, and monitorThread is set for deprecation/deletion
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/adc4f2da Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/adc4f2da Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/adc4f2da Branch: refs/heads/STREAMS-212 Commit: adc4f2da14105fd3108e78b2781334bf34286330 Parents: dce7d35 Author: sblackmon <[email protected]> Authored: Thu Nov 20 17:22:50 2014 -0600 Committer: sblackmon <[email protected]> Committed: Thu Nov 20 17:22:50 2014 -0600 ---------------------------------------------------------------------- .../java/org/apache/streams/local/builders/LocalStreamBuilder.java | 2 -- 1 file changed, 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/adc4f2da/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java ---------------------------------------------------------------------- diff --git a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java index e25a41b..38c9e43 100644 --- a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java +++ b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java @@ -205,8 +205,6 @@ public class LocalStreamBuilder implements StreamBuilder { boolean forcedShutDown = false; try { -// monitorThread = new LocalStreamProcessMonitorThread(executor, 10); -// this.monitor.submit(monitorThread); if( broadcastMonitor.getWaitTime() != -1 ) this.monitor.submit(broadcastMonitor); setupComponentTasks(tasks);
