You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2022/06/30 15:04:00 UTC
[jira] [Work logged] (ARTEMIS-3815) Target mirror controller may commit received message after receiving ACK for it
[ https://issues.apache.org/jira/browse/ARTEMIS-3815?focusedWorklogId=786647&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-786647 ]
ASF GitHub Bot logged work on ARTEMIS-3815:
-------------------------------------------
Author: ASF GitHub Bot
Created on: 30/Jun/22 15:03
Start Date: 30/Jun/22 15:03
Worklog Time Spent: 10m
Work Description: clebertsuconic commented on PR #4066:
URL: https://github.com/apache/activemq-artemis/pull/4066#issuecomment-1171334240
you have some changes on your commit that are not really part of your change.. it makes a bit difficult to Rebase it :)
You should have done the reformat on a separate commit.
Issue Time Tracking
-------------------
Worklog Id: (was: 786647)
Remaining Estimate: 0h
Time Spent: 10m
> Target mirror controller may commit received message after receiving ACK for it
> -------------------------------------------------------------------------------
>
> Key: ARTEMIS-3815
> URL: https://issues.apache.org/jira/browse/ARTEMIS-3815
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Components: AMQP
> Affects Versions: 2.19.1, 2.21.0, 2.22.0
> Reporter: Iliya Grushevskiy
> Priority: Major
> Time Spent: 10m
> Remaining Estimate: 0h
>
> Given two brokers *A* and {*}B{*}, with configured mirror *A* towards *B* and a queue {*}Q{*}. If disk operations on *B* are slow, and there are active exchanges of messages on queue {*}Q{*}, for example:
> # Send message 1
> # ACK message 1
> # Send message 2
> # ACK message 2
> # ...
> At the end queue *Q* on *B* will contain some unacknowledged messages, while queue *Q* on *A* will be empty.
> The issue is that commit in sendMessage may take some time and ref to message will be written to the intermediate store only after receiving an ACK for this message.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)