[ https://issues.apache.org/jira/browse/ARTEMIS-2894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197021#comment-17197021 ]
Gaetan Caumartin commented on ARTEMIS-2894: ------------------------------------------- I added logs from the broker plugin LoggingActiveMQServerPlugin. Could you tell me which package I should pass in TRACE? > 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 > Attachments: Broker 1 with messages (broker-plugin logs).txt, Broker > 2 with consumer (broker-plugin logs).txt, 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)