You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Jonathan Gallimore (Jira)" <ji...@apache.org> on 2021/03/24 09:35:00 UTC
[jira] [Commented] (AMQ-8201) ACK compaction with local
transactions
[ https://issues.apache.org/jira/browse/AMQ-8201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17307707#comment-17307707 ]
Jonathan Gallimore commented on AMQ-8201:
-----------------------------------------
This is related to Jira issue AMQ-7067 (https://issues.apache.org/jira/browse/AMQ-7067) - the previous functionality only forwarded the remove message command, and was changed to also forward commits with XA transactions - it looks like local transactions were missed.
Thank you Chris, Gary and JB for your review and feedback!
> ACK compaction with local transactions
> --------------------------------------
>
> Key: AMQ-8201
> URL: https://issues.apache.org/jira/browse/AMQ-8201
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.16.1, 5.15.14
> Reporter: Jonathan Gallimore
> Priority: Major
>
> I have a consumer running with transacted sessions, and looking in KahaDB, I can see a KAHA_REMOVE_MESSAGE_COMMAND, with the local transaction ID added to the journal, and then a KAHA_COMMIT_COMMAND after it. Some time later, I see the exact same KAHA_REMOVE_MESSAGE_COMMAND appended to the journal again, with the exact same transaction information, but no corresponding KAHA_COMMIT_COMMAND. This appears to follow a KAHA_REWRITTEN_DATA_FILE_COMMAND.
>
> It looks like the ack compaction method is forwarding the acknowledgement, but not the commit - it appears that the commit is only forwarded in the case of an XA transaction.
>
> A test and patch is available in the PR here: https://github.com/apache/activemq/pull/636
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)