Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-4128 Added "All" MessageAttributeNames to GetSQS processor ReceiveMessageRequest 

Signed-off-by: James Wing <jvwing@gmail.com>

This closes #1949.
This commit is contained in:
kwydler 2017-06-26 21:06:21 -04:00 committed by James Wing
parent 2b5aaec6d9
commit c37aed4de2
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
nifi-nar-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/sqs/GetSQS.java
View File

@ -138,6 +138,7 @@ public class GetSQS extends AbstractSQSProcessor {
final ReceiveMessageRequest request = new ReceiveMessageRequest(); final ReceiveMessageRequest request = new ReceiveMessageRequest();
request.setAttributeNames(Collections.singleton("All")); request.setAttributeNames(Collections.singleton("All"));
request.setMessageAttributeNames(Collections.singleton("All"));
request.setMaxNumberOfMessages(context.getProperty(BATCH_SIZE).asInteger()); request.setMaxNumberOfMessages(context.getProperty(BATCH_SIZE).asInteger());
request.setVisibilityTimeout(context.getProperty(VISIBILITY_TIMEOUT).asTimePeriod(TimeUnit.SECONDS).intValue()); request.setVisibilityTimeout(context.getProperty(VISIBILITY_TIMEOUT).asTimePeriod(TimeUnit.SECONDS).intValue());
request.setQueueUrl(queueUrl); request.setQueueUrl(queueUrl);