From c37aed4de291936ea684f0e2ef1a0bd33285d643 Mon Sep 17 00:00:00 2001 From: kwydler Date: Mon, 26 Jun 2017 21:06:21 -0400 Subject: [PATCH] NIFI-4128 Added "All" MessageAttributeNames to GetSQS processor ReceiveMessageRequest Signed-off-by: James Wing This closes #1949. --- .../src/main/java/org/apache/nifi/processors/aws/sqs/GetSQS.java | 1 + 1 file changed, 1 insertion(+) 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 5dc6f1293f..eebc731e87 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);