nifi-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Oleg Zhurakousky (JIRA)" <>
Subject [jira] [Commented] (NIFI-2774) ConsumeJMS processor losses messages on NiFi restart
Date Wed, 14 Sep 2016 15:54:20 GMT


Oleg Zhurakousky commented on NIFI-2774:

[] it will actually be handled with local TX where there will be explicit
commits and rollbacks. More reliable and easier to follow. The fix is already in place, just
adding tests to validate the behavior
Thank you for pointing this out!

> ConsumeJMS processor losses messages on NiFi restart
> ----------------------------------------------------
>                 Key: NIFI-2774
>                 URL:
>             Project: Apache NiFi
>          Issue Type: Bug
>          Components: Core Framework
>    Affects Versions: 1.0.0, 0.7.0, 1.1.0, 0.8.0
>            Reporter: Christopher McDermott
>            Priority: Critical
>             Fix For: 1.1.0, 0.8.0
> ConsumeJMS processor uses auto-acknowledge mode.  Unlike the deprecated GetJMSQueue processor
it does not provide a way to specify a different ACK mode (i.e. client-acknowledge.)  Using
auto-acknowledge, acknowledges message receipt from JMS *before* the messages are actually
added to the flow.  This leads to data-loss on NiFi stop (or crash.)
> I believe the fix for this is to allow the user to specify the ACK mode in the processor
configuration like is allowed by the GetJMSQueue processor.

This message was sent by Atlassian JIRA

View raw message