You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Gaetan Caumartin (Jira)" <ji...@apache.org> on 2020/11/25 16:23:00 UTC
[jira] [Resolved] (ARTEMIS-2894) Message redistribution don't work
anymore when paging start on cluster address
[ https://issues.apache.org/jira/browse/ARTEMIS-2894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gaetan Caumartin resolved ARTEMIS-2894.
---------------------------------------
Fix Version/s: 2.16.0
Resolution: Fixed
The 2.16 seems to have solve this issue
> Message redistribution don't work anymore when paging start on cluster address
> ------------------------------------------------------------------------------
>
> Key: ARTEMIS-2894
> URL: https://issues.apache.org/jira/browse/ARTEMIS-2894
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Affects Versions: 2.12.0, 2.13.0, 2.14.0, 2.15.0
> Reporter: Gaetan Caumartin
> Priority: Major
> Fix For: 2.16.0
>
> Attachments: Broker 1 with messages (broker-plugin logs).txt, Broker 2 with consumer (broker-plugin logs).txt, MessageRedistributionPagingTest.java, broker.xml
>
>
> I was trying to reproduce the same network of broker architecture that I had with activemq brokers by using an artemis cluster.
> Everything was ok in version 2.11.0, I was able to store millions of messages and to consume them later from another broker inside the same cluster.
> Since the version 2.12.0 I encounter an issue. I'm still able to produce a huge quantity of messages thanks to the paging mechanism but when I try to consume them from another broker I'm not able to get all of them (most of them disappear).
>
> I'm able to reproduce this issue like this on 2.12.0, 2.13.0, 2.14.0 and 2.15.0 versions:
> * Start a cluster with 2 brokers (with ON_DEMAND, redistribution-delay=0 and with address full policy set with PAGE)
> * Produce messages on a queue on the first broker until paging starts for this queue
> ** ./artemis producer --destination AMQ.QUEUE --message-count 550000 --message-size 1000
> ** from the logs: Starting paging on address 'AMQ.QUEUE'
> ; size is currently: 1,073,742,120 bytes; max-size-bytes: -1; global-size-bytes: 1,073,742,120
> * On the second broker, starts to consume messages on the same queue
> ** ./artemis consumer --destination AMQ.QUEUE --message-count 550000
> * The consumer receives a few messages and then it stops when the paging starts on the clustered address
> ** Consumer still waiting for messages
> ** from the logs: Starting paging on address '$.artemis.
> internal.sf.my-cluster.335036cc-edc0-11ea-bae1-005056a7672b'; size is currently: 2,259 bytes; max-size-bytes: -1; global-size-bytes: 1,073,744,379
> ** messages move from AMQ.QUEUE to $.artemis.internal.sf.my-cluster.335036cc-edc0-11ea-bae1-005056a7672b and appeared as acknowledged on both queue of the first broker but doesn't appear on the second broker.
> ** Finally the queues are empty and the consumer didn't receives the messages since the paging starts on the clustered address
> I will continue to investigate this issue with more debug/trace.
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)