Repository: nifi Updated Branches: refs/heads/master 2b5aaec6d -> c37aed4de
NIFI-4128 Added "All" MessageAttributeNames to GetSQS processor ReceiveMessageRequest Signed-off-by: James Wing <[email protected]> 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 <[email protected]> Authored: Mon Jun 26 21:06:21 2017 -0400 Committer: James Wing <[email protected]> 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);
