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:56 UTC

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

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);
     }
 
     /**