This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit 7900b297ce12d7d92215408d8d96acfb063b2749 Author: Claus Ibsen <[email protected]> AuthorDate: Mon Sep 2 12:18:12 2019 +0200 CAMEL-13917: Configuring endpoints with consumer. prefix for consumer options is no longer supported as they should be regular options instead. This also avoid reflection setting properties. --- .../src/main/java/org/apache/camel/component/aws/sqs/SqsComponent.java | 2 +- .../org/apache/camel/component/beanstalk/ConsumerCompletionTest.java | 2 +- .../org/apache/camel/component/beanstalk/ImmediateConsumerTest.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/components/camel-aws-sqs/src/main/java/org/apache/camel/component/aws/sqs/SqsComponent.java b/components/camel-aws-sqs/src/main/java/org/apache/camel/component/aws/sqs/SqsComponent.java index e6ec965..fd6b4c3 100644 --- a/components/camel-aws-sqs/src/main/java/org/apache/camel/component/aws/sqs/SqsComponent.java +++ b/components/camel-aws-sqs/src/main/java/org/apache/camel/component/aws/sqs/SqsComponent.java @@ -94,7 +94,7 @@ public class SqsComponent extends DefaultComponent { } SqsEndpoint sqsEndpoint = new SqsEndpoint(uri, this, configuration); - sqsEndpoint.setConsumerProperties(parameters); + setProperties(sqsEndpoint, parameters); return sqsEndpoint; } diff --git a/components/camel-beanstalk/src/test/java/org/apache/camel/component/beanstalk/ConsumerCompletionTest.java b/components/camel-beanstalk/src/test/java/org/apache/camel/component/beanstalk/ConsumerCompletionTest.java index cea9569..b596d83 100644 --- a/components/camel-beanstalk/src/test/java/org/apache/camel/component/beanstalk/ConsumerCompletionTest.java +++ b/components/camel-beanstalk/src/test/java/org/apache/camel/component/beanstalk/ConsumerCompletionTest.java @@ -149,7 +149,7 @@ public class ConsumerCompletionTest extends BeanstalkMockTestSupport { return new RouteBuilder() { @Override public void configure() { - from("beanstalk:tube?consumer.onFailure=release").routeId("foo") + from("beanstalk:tube?onFailure=release").routeId("foo") .process(processor).to("mock:result"); } }; diff --git a/components/camel-beanstalk/src/test/java/org/apache/camel/component/beanstalk/ImmediateConsumerTest.java b/components/camel-beanstalk/src/test/java/org/apache/camel/component/beanstalk/ImmediateConsumerTest.java index 9631742..17d17b0 100644 --- a/components/camel-beanstalk/src/test/java/org/apache/camel/component/beanstalk/ImmediateConsumerTest.java +++ b/components/camel-beanstalk/src/test/java/org/apache/camel/component/beanstalk/ImmediateConsumerTest.java @@ -96,7 +96,7 @@ public class ImmediateConsumerTest extends BeanstalkMockTestSupport { return new RouteBuilder() { @Override public void configure() { - from("beanstalk:tube?consumer.awaitJob=false").process(processor).to("mock:result"); + from("beanstalk:tube?awaitJob=false").process(processor).to("mock:result"); } }; }
