STREAMS-179 | Added javdoc comments.
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/2397f4b4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/2397f4b4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/2397f4b4 Branch: refs/heads/STREAMS-170 Commit: 2397f4b480448ebd3e1a3c4efa4d9dc5ef64750a Parents: e091c6c Author: Ryan Ebanks <rebanks@Informations-MacBook-Pro-3.local> Authored: Fri Sep 19 15:24:22 2014 -0500 Committer: Ryan Ebanks <rebanks@Informations-MacBook-Pro-3.local> Committed: Fri Sep 19 15:24:22 2014 -0500 ---------------------------------------------------------------------- .../ShutdownStreamOnUnhandleThrowableThreadPoolExecutor.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/2397f4b4/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/executors/ShutdownStreamOnUnhandleThrowableThreadPoolExecutor.java ---------------------------------------------------------------------- diff --git a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/executors/ShutdownStreamOnUnhandleThrowableThreadPoolExecutor.java b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/executors/ShutdownStreamOnUnhandleThrowableThreadPoolExecutor.java index f8d6343..55a26e1 100644 --- a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/executors/ShutdownStreamOnUnhandleThrowableThreadPoolExecutor.java +++ b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/executors/ShutdownStreamOnUnhandleThrowableThreadPoolExecutor.java @@ -7,6 +7,7 @@ import org.slf4j.LoggerFactory; import java.util.concurrent.*; /** + * A fixed ThreadPoolExecutor that will shutdown a stream upon a thread ending execution due to an unhandled throwable. * @see {@link java.util.concurrent.ThreadPoolExecutor} */ public class ShutdownStreamOnUnhandleThrowableThreadPoolExecutor extends ThreadPoolExecutor {
