You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by co...@apache.org on 2019/11/06 20:09:25 UTC

[camel] 02/02: Fixing failing camel-sjms test on 2.x

This is an automated email from the ASF dual-hosted git repository.

coheigea pushed a commit to branch camel-2.x
in repository https://gitbox.apache.org/repos/asf/camel.git

commit fed1e9e3af20557e231cff04411465df9eb16ab3
Author: Colm O hEigeartaigh <co...@apache.org>
AuthorDate: Wed Nov 6 16:26:55 2019 +0000

    Fixing failing camel-sjms test on 2.x
---
 .../org/apache/camel/component/sjms/batch/SjmsBatchConsumerTest.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/SjmsBatchConsumerTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/SjmsBatchConsumerTest.java
index a611be1..44d96c1 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/SjmsBatchConsumerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/SjmsBatchConsumerTest.java
@@ -27,6 +27,7 @@ import org.apache.camel.Exchange;
 import org.apache.camel.LoggingLevel;
 import org.apache.camel.Message;
 import org.apache.camel.Processor;
+import org.apache.camel.impl.PropertyPlaceholderDelegateRegistry;
 import org.apache.camel.util.toolbox.AggregationStrategies;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.mock.MockEndpoint;
@@ -408,7 +409,8 @@ public class SjmsBatchConsumerTest extends CamelTestSupport {
         context.addRoutes(new TransactedSendHarness(queueName));
         context.addRoutes(new RouteBuilder() {
             public void configure() throws Exception {
-                ((SimpleRegistry)context.getRegistry()).put("groupedStrategy", AggregationStrategies.groupedBody());
+                SimpleRegistry registry = (SimpleRegistry)((PropertyPlaceholderDelegateRegistry)context.getRegistry()).getRegistry();
+                registry.put("groupedStrategy", AggregationStrategies.groupedBody());
 
                 fromF("sjms-batch:%s?completionSize=%s&aggregationStrategy=#groupedStrategy",
                         queueName, completionSize).routeId("batchConsumer").startupOrder(10)