You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Jean-Pascal Briquet (Jira)" <ji...@apache.org> on 2024/07/08 10:08:00 UTC
[jira] [Updated] (ARTEMIS-4904) Mirroring not replicating messages after message move operation
[ https://issues.apache.org/jira/browse/ARTEMIS-4904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jean-Pascal Briquet updated ARTEMIS-4904:
-----------------------------------------
Description:
Mirroring may not replicate messages when an operator uses the message move operation available from JMX or UI console.
Messages are not replicated after the process of moving messages has finished, even if the target queue of the move operation is replicated via mirroring.
The following issue has been seen on a configuration with two Artemis brokers with bi-directional (dual) mirroring enabled.
Setup:
- Artemis broker 1 "mirroring on" Artemis broker 2
- Artemis broker 2 "mirroring on" Artemis broker 1
*Scenario:*
If messages are injected on broker 1 "queue.A", messages are replicated on broker 2 "queue.A" via mirroring
- When the move operation to "queue.B" is performed on broker 1, messages are correctly replicated on broker 2 "queue.B" after the move
- When the move operation to "queue.B" is performed on broker 2, messages disappear from broker 1 "queue.A" (acks are received) but messages are not replicated on broker 1 "queue.B" after the move.
*Test case:*
An integration test case is provided in attachment. To run it, add test code into AMQPReplicaTest class under Artemis integration-tests package.
*Logs:*
The following log appears on broker 2 and could be linked to the problem
2024-07-08 12:02:06,069 TRACE [org.apache.activemq.artemis.protocol.amqp.connect.mirror.AMQPMirrorControllerSource] {*}sendMessage::Message AMQPStandardMessage{*}( [durable=true, messageID=95, address=testMessageMove.moved, size=303, scanningStatus=SCANNED, applicationProperties=\{i=7}, messageAnnotations=\{x-opt-jms-dest=0, x-opt-jms-msg-type=5, x-opt-ORIG-QUEUE=testMessageMove, x-opt-ORIG-ADDRESS=testMessageMove, x-opt-ORIG-MESSAGE-ID=58, x-opt-ORIG-ROUTING-TYPE=1}, properties=Properties\{messageId=ID:f12bc95c-a09a-4c50-ad43-d55e592c7347:1:1:1-8, userId=null, to='testMessageMove.moved', subject='null', replyTo='null', correlationId=null, contentType=null, contentEncoding=null, absoluteExpiryTime=null, creationTime=Mon Jul 08 12:02:05 CEST 2024, groupId='null', groupSequence=null, replyToGroupId='null'}, extraProperties = TypedProperties[x-opt-amq-bkr-id=2018f725-3d11-11ef-88d6-00155d092ac8, _AMQ_ORIG_QUEUE=testMessageMove, _AMQ_AD=testMessageMove.moved, _AMQ_ORIG_ROUTING_TYPE=1, _AMQ_ORIG_ADDRESS=testMessageMove, x-opt-amq-mr-id=44, _AMQ_ORIG_MESSAGE_ID=58]] {*}already belonged to the node{*}, 2018f725-3d11-11ef-88d6-00155d092ac8, *it won't circle send*
was:
Mirroring may not replicate messages when an operator uses the message move operation available from JMX or UI console.
Messages are not replicated after the process of moving messages has finished, even if the target queue of the move operation is replicated via mirroring.
The following issue has been seen on a configuration with two Artemis brokers with bi-directional (dual) mirroring enabled.
Setup:
- Artemis broker 1 "mirroring on" Artemis broker 2
- Artemis broker 2 "mirroring on" Artemis broker 1
*Scenario:*
If messages are injected on broker 1 "queue.A", messages are replicated on broker 2 "queue.A" via mirroring
- When the move operation to "queue.B" is performed on broker 1, messages are correctly replicated on broker 2 "queue.B" after the move
- When the move operation to "queue.B" is performed on broker 2, messages disappear from broker 1 "queue.A" (acks are received) but messages are not replicated on broker 1 "queue.B" after the move.
*Test case:*
An integration test case is provided in attachment. To run it, add test code into AMQPReplicaTest class under Artemis integration-tests package.
*Logs:*
The following log appears on broker 2 and could be linked to the problem
2024-07-08 12:02:06,069 TRACE [org.apache.activemq.artemis.protocol.amqp.connect.mirror.AMQPMirrorControllerSource] {*}sendMessage::Message AMQPStandardMessage{*}( [durable=true, messageID=95, address=testMessageMove.moved, size=303, scanningStatus=SCANNED, applicationProperties=\{i=7}, messageAnnotations=\{x-opt-jms-dest=0, x-opt-jms-msg-type=5, x-opt-ORIG-QUEUE=testMessageMove, x-opt-ORIG-ADDRESS=testMessageMove, x-opt-ORIG-MESSAGE-ID=58, x-opt-ORIG-ROUTING-TYPE=1}, properties=Properties\{messageId=ID:f12bc95c-a09a-4c50-ad43-d55e592c7347:1:1:1-8, userId=null, to='testMessageMove.moved', subject='null', replyTo='null', correlationId=null, contentType=null, contentEncoding=null, absoluteExpiryTime=null, creationTime=Mon Jul 08 12:02:05 CEST 2024, groupId='null', groupSequence=null, replyToGroupId='null'}, extraProperties = TypedProperties[x-opt-amq-bkr-id=2018f725-3d11-11ef-88d6-00155d092ac8, _AMQ_ORIG_QUEUE=testMessageMove, _AMQ_AD=testMessageMove.moved, _AMQ_ORIG_ROUTING_TYPE=1, _AMQ_ORIG_ADDRESS=testMessageMove, x-opt-amq-mr-id=44, _AMQ_ORIG_MESSAGE_ID=58]] already belonged to the node, 2018f725-3d11-11ef-88d6-00155d092ac8, *it won't circle send*
> Mirroring not replicating messages after message move operation
> ---------------------------------------------------------------
>
> Key: ARTEMIS-4904
> URL: https://issues.apache.org/jira/browse/ARTEMIS-4904
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Components: Broker, management
> Affects Versions: 2.35.0
> Reporter: Jean-Pascal Briquet
> Priority: Major
> Attachments: message-move-mirroring-test-case.java
>
>
> Mirroring may not replicate messages when an operator uses the message move operation available from JMX or UI console.
> Messages are not replicated after the process of moving messages has finished, even if the target queue of the move operation is replicated via mirroring.
> The following issue has been seen on a configuration with two Artemis brokers with bi-directional (dual) mirroring enabled.
> Setup:
> - Artemis broker 1 "mirroring on" Artemis broker 2
> - Artemis broker 2 "mirroring on" Artemis broker 1
> *Scenario:*
> If messages are injected on broker 1 "queue.A", messages are replicated on broker 2 "queue.A" via mirroring
> - When the move operation to "queue.B" is performed on broker 1, messages are correctly replicated on broker 2 "queue.B" after the move
> - When the move operation to "queue.B" is performed on broker 2, messages disappear from broker 1 "queue.A" (acks are received) but messages are not replicated on broker 1 "queue.B" after the move.
>
> *Test case:*
> An integration test case is provided in attachment. To run it, add test code into AMQPReplicaTest class under Artemis integration-tests package.
>
> *Logs:*
> The following log appears on broker 2 and could be linked to the problem
> 2024-07-08 12:02:06,069 TRACE [org.apache.activemq.artemis.protocol.amqp.connect.mirror.AMQPMirrorControllerSource] {*}sendMessage::Message AMQPStandardMessage{*}( [durable=true, messageID=95, address=testMessageMove.moved, size=303, scanningStatus=SCANNED, applicationProperties=\{i=7}, messageAnnotations=\{x-opt-jms-dest=0, x-opt-jms-msg-type=5, x-opt-ORIG-QUEUE=testMessageMove, x-opt-ORIG-ADDRESS=testMessageMove, x-opt-ORIG-MESSAGE-ID=58, x-opt-ORIG-ROUTING-TYPE=1}, properties=Properties\{messageId=ID:f12bc95c-a09a-4c50-ad43-d55e592c7347:1:1:1-8, userId=null, to='testMessageMove.moved', subject='null', replyTo='null', correlationId=null, contentType=null, contentEncoding=null, absoluteExpiryTime=null, creationTime=Mon Jul 08 12:02:05 CEST 2024, groupId='null', groupSequence=null, replyToGroupId='null'}, extraProperties = TypedProperties[x-opt-amq-bkr-id=2018f725-3d11-11ef-88d6-00155d092ac8, _AMQ_ORIG_QUEUE=testMessageMove, _AMQ_AD=testMessageMove.moved, _AMQ_ORIG_ROUTING_TYPE=1, _AMQ_ORIG_ADDRESS=testMessageMove, x-opt-amq-mr-id=44, _AMQ_ORIG_MESSAGE_ID=58]] {*}already belonged to the node{*}, 2018f725-3d11-11ef-88d6-00155d092ac8, *it won't circle send*
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@activemq.apache.org
For additional commands, e-mail: issues-help@activemq.apache.org
For further information, visit: https://activemq.apache.org/contact