[java-metadata-aggregator] branch master updated: MDA-206 - waitingForPipelines property should be true by default

[Ian Young]

This is an automated email from the git hooks/post-receive script.

iay pushed a commit to branch master
in repository java-metadata-aggregator.

View the commit online:
http://git.shibboleth.net/view/?p=java-metadata-aggregator.git;a=commit;h=4c39d72886acda21f64756362982ec73241b9fae

The following commit(s) were added to refs/heads/master by this push:
       new  4c39d72   MDA-206 - waitingForPipelines property should be true by default
4c39d72 is described below

commit 4c39d72886acda21f64756362982ec73241b9fae
Author: Ian Young <ian at iay.org.uk>
AuthorDate: Wed Aug 22 17:06:44 2018 +0100

    MDA-206 - waitingForPipelines property should be true by default
---
 .../shibboleth/metadata/pipeline/PipelineDemultiplexerStage.java  | 8 ++++++--
 .../metadata/pipeline/PipelineDemultiplexerStageTest.java         | 5 +++++
 2 files changed, 11 insertions(+), 2 deletions(-)

diff --git a/aggregator-pipeline/src/main/java/net/shibboleth/metadata/pipeline/PipelineDemultiplexerStage.java b/aggregator-pipeline/src/main/java/net/shibboleth/metadata/pipeline/PipelineDemultiplexerStage.java
index 0c26c0e..821104e 100644
--- a/aggregator-pipeline/src/main/java/net/shibboleth/metadata/pipeline/PipelineDemultiplexerStage.java
+++ b/aggregator-pipeline/src/main/java/net/shibboleth/metadata/pipeline/PipelineDemultiplexerStage.java
@@ -67,8 +67,12 @@ public class PipelineDemultiplexerStage<T> extends AbstractStage<T> {
     /** Service used to execute the selected and/or non-selected item pipelines. */
     private ExecutorService executorService = Executors.newSingleThreadExecutor();
 
-    /** Whether this child waits for all the invoked pipelines to complete before proceeding. */
-    private boolean waitingForPipelines;
+    /**
+     * Whether this child waits for all the invoked pipelines to complete before proceeding.
+     *
+     * Default: <code>true</code>.
+     */
+    private boolean waitingForPipelines = true;
 
     /** Factory used to create the Item collection that is then given to the pipelines. */
     private Supplier<Collection<Item<T>>> collectionFactory = new SimpleItemCollectionFactory<>();
diff --git a/aggregator-pipeline/src/test/java/net/shibboleth/metadata/pipeline/PipelineDemultiplexerStageTest.java b/aggregator-pipeline/src/test/java/net/shibboleth/metadata/pipeline/PipelineDemultiplexerStageTest.java
index 62fcbed..c28fbaa 100644
--- a/aggregator-pipeline/src/test/java/net/shibboleth/metadata/pipeline/PipelineDemultiplexerStageTest.java
+++ b/aggregator-pipeline/src/test/java/net/shibboleth/metadata/pipeline/PipelineDemultiplexerStageTest.java
@@ -141,4 +141,9 @@ public class PipelineDemultiplexerStageTest {
             // this was expected
         }
     }
+
+    @Test public void testMDA206() throws Exception {
+        final PipelineDemultiplexerStage<String> stage = new PipelineDemultiplexerStage<>();
+        Assert.assertTrue(stage.isWaitingForPipelines());
+    }
 }
\ No newline at end of file

-- 
To stop receiving notification emails like this one, please contact
the administrator of this repository.