You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2013/10/28 09:50:55 UTC

[1/2] git commit: CAMEL-6890: Fixed test and little mistake in the sqs consumer.

Updated Branches:
  refs/heads/camel-2.12.x d12cba339 -> 5275d2691
  refs/heads/master 5354782c4 -> 43261460d


CAMEL-6890: Fixed test and little mistake in the sqs consumer.


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/43261460
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/43261460
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/43261460

Branch: refs/heads/master
Commit: 43261460db1a3ea5a1246f57b9cd542581245bdd
Parents: 5354782
Author: Claus Ibsen <da...@apache.org>
Authored: Mon Oct 28 09:50:40 2013 +0100
Committer: Claus Ibsen <da...@apache.org>
Committed: Mon Oct 28 09:50:40 2013 +0100

----------------------------------------------------------------------
 .../main/java/org/apache/camel/component/aws/sqs/SqsConsumer.java | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/43261460/components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsConsumer.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsConsumer.java
index 4c76c15..1163743 100644
--- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsConsumer.java
+++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsConsumer.java
@@ -204,8 +204,7 @@ public class SqsConsumer extends ScheduledBatchPollingConsumer {
     }
 
     private boolean passedThroughFilter(Exchange exchange) {
-        return exchange.getProperties().containsKey(Exchange.FILTER_MATCHED)
-                && ((Boolean) exchange.getProperties().get(Exchange.FILTER_MATCHED));
+        return exchange.getProperty(Exchange.FILTER_MATCHED, false, Boolean.class);
     }
 
     /**


[2/2] git commit: CAMEL-6890: Fixed test and little mistake in the sqs consumer.

Posted by da...@apache.org.
CAMEL-6890: Fixed test and little mistake in the sqs consumer.


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/5275d269
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/5275d269
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/5275d269

Branch: refs/heads/camel-2.12.x
Commit: 5275d269111381ec74ddeb894fa6c42da18a2b4d
Parents: d12cba3
Author: Claus Ibsen <da...@apache.org>
Authored: Mon Oct 28 09:50:40 2013 +0100
Committer: Claus Ibsen <da...@apache.org>
Committed: Mon Oct 28 09:50:55 2013 +0100

----------------------------------------------------------------------
 .../main/java/org/apache/camel/component/aws/sqs/SqsConsumer.java | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/5275d269/components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsConsumer.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsConsumer.java
index 4c76c15..1163743 100644
--- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsConsumer.java
+++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsConsumer.java
@@ -204,8 +204,7 @@ public class SqsConsumer extends ScheduledBatchPollingConsumer {
     }
 
     private boolean passedThroughFilter(Exchange exchange) {
-        return exchange.getProperties().containsKey(Exchange.FILTER_MATCHED)
-                && ((Boolean) exchange.getProperties().get(Exchange.FILTER_MATCHED));
+        return exchange.getProperty(Exchange.FILTER_MATCHED, false, Boolean.class);
     }
 
     /**