Repository: camel Updated Branches: refs/heads/camel-2.19.x 93ec6f3a7 -> 80544f4d5 refs/heads/master c1390a40f -> 83f50465f
CAMEL-11862: Added unit test Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/83f50465 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/83f50465 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/83f50465 Branch: refs/heads/master Commit: 83f50465f7b6b8cbb75aee5504c6aabece8068a9 Parents: 7b459d7 Author: Claus Ibsen <davscl...@apache.org> Authored: Thu Sep 28 13:45:08 2017 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Thu Sep 28 13:45:44 2017 +0200 ---------------------------------------------------------------------- .../camel/component/seda/SedaConcurrentConsumersTest.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/83f50465/camel-core/src/test/java/org/apache/camel/component/seda/SedaConcurrentConsumersTest.java ---------------------------------------------------------------------- diff --git a/camel-core/src/test/java/org/apache/camel/component/seda/SedaConcurrentConsumersTest.java b/camel-core/src/test/java/org/apache/camel/component/seda/SedaConcurrentConsumersTest.java index 75634e3..601cf84 100644 --- a/camel-core/src/test/java/org/apache/camel/component/seda/SedaConcurrentConsumersTest.java +++ b/camel-core/src/test/java/org/apache/camel/component/seda/SedaConcurrentConsumersTest.java @@ -19,12 +19,20 @@ package org.apache.camel.component.seda; import org.apache.camel.ContextTestSupport; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.mock.MockEndpoint; +import org.apache.camel.impl.JndiRegistry; /** * @version */ public class SedaConcurrentConsumersTest extends ContextTestSupport { + @Override + protected JndiRegistry createRegistry() throws Exception { + JndiRegistry jndi = super.createRegistry(); + jndi.bind("count", "5"); + return jndi; + } + public void testSendToSeda() throws Exception { MockEndpoint mock = getMockEndpoint("mock:result"); mock.expectedBodiesReceived("Hello World"); @@ -39,7 +47,7 @@ public class SedaConcurrentConsumersTest extends ContextTestSupport { return new RouteBuilder() { @Override public void configure() throws Exception { - from("seda:foo?concurrentConsumers=5").to("mock:result"); + from("seda:foo?concurrentConsumers=#count").to("mock:result"); } }; }
