[
https://issues.apache.org/jira/browse/NIFI-4540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16353365#comment-16353365
]
James Wing commented on NIFI-4540:
----------------------------------
[~SunSatION], thanks for submitting this patch, I agree FIFO queue support is
a feature gap we would love to fill. I did a quick pass on applying it,
compiling, running, and testing. I ran into compiler errors for missing imports
Collection and SendMessageBatchResult.
The code as submitted appears to work OK only with FIFO queues that have
Content-Based Deduplication enabled. Otherwise, an exception is thrown about
the absence of a deduplication id in the request:
{quote}2018-02-06 05:08:30,884 ERROR [Timer-Driven Process Thread-1]
o.apache.nifi.processors.aws.sqs.PutSQS
PutSQS[id=697edb3a-0161-1000-71aa-22cc71a0e96d] Failed to send messages to
Amazon SQS due to com.amazonaws.services.sqs.model.AmazonSQSException: The
queue should either have ContentBasedDeduplication enabled or
MessageDeduplicationId provided explicitly (Service: AmazonSQS; Status Code:
400; Error Code: InvalidParameterValue; Request ID:
4be71d3c-3abd-5f2e-b8a8-4fcf00332e2b); routing to failure: {}
{quote} * Would you be willing to add Deduplication Id? If not, would you
please update the processor documentation annotations to not the requirement of
a Content-Based Deduplication queue?
* Would you be willing to update a unit test to cover the FIFO case?
> Support for AWS SQS FIFO message queue
> --------------------------------------
>
> Key: NIFI-4540
> URL: https://issues.apache.org/jira/browse/NIFI-4540
> Project: Apache NiFi
> Issue Type: Improvement
> Components: Core Framework
> Affects Versions: 1.4.0
> Reporter: Dorian Bugeja
> Priority: Major
> Labels: easyfix, features, newbie
> Attachments: NIFI_4540___Support_for_AWS_SQS_FIFO_message_queue.patch
>
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
