You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by jw...@apache.org on 2017/06/27 05:25:49 UTC
nifi git commit: NIFI-4128 Added "All" MessageAttributeNames to
GetSQS processor ReceiveMessageRequest
Repository: nifi
Updated Branches:
refs/heads/master 2b5aaec6d -> c37aed4de
NIFI-4128 Added "All" MessageAttributeNames to GetSQS processor ReceiveMessageRequest
Signed-off-by: James Wing <jv...@gmail.com>
This closes #1949.
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/c37aed4d
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/c37aed4d
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/c37aed4d
Branch: refs/heads/master
Commit: c37aed4de291936ea684f0e2ef1a0bd33285d643
Parents: 2b5aaec
Author: kwydler <kw...@gmail.com>
Authored: Mon Jun 26 21:06:21 2017 -0400
Committer: James Wing <jv...@gmail.com>
Committed: Mon Jun 26 22:25:16 2017 -0700
----------------------------------------------------------------------
.../src/main/java/org/apache/nifi/processors/aws/sqs/GetSQS.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/c37aed4d/nifi-nar-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/sqs/GetSQS.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/sqs/GetSQS.java b/nifi-nar-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/sqs/GetSQS.java
index 5dc6f12..eebc731 100644
--- a/nifi-nar-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/sqs/GetSQS.java
+++ b/nifi-nar-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/sqs/GetSQS.java
@@ -138,6 +138,7 @@ public class GetSQS extends AbstractSQSProcessor {
final ReceiveMessageRequest request = new ReceiveMessageRequest();
request.setAttributeNames(Collections.singleton("All"));
+ request.setMessageAttributeNames(Collections.singleton("All"));
request.setMaxNumberOfMessages(context.getProperty(BATCH_SIZE).asInteger());
request.setVisibilityTimeout(context.getProperty(VISIBILITY_TIMEOUT).asTimePeriod(TimeUnit.SECONDS).intValue());
request.setQueueUrl(queueUrl);