[prev in list] [next in list] [prev in thread] [next in thread] 

List:       activemq-dev
Subject:    [jira] [Commented] (AMQ-5322) Message is assigned to different client with the same JMSXGroupID
From:       "Igor Samardzija (JIRA)" <jira () apache ! org>
Date:       2014-10-31 8:28:34
Message-ID: JIRA.12733992.1408002445000.380917.1414744114049 () Atlassian ! JIRA
[Download RAW message or body]


    [ https://issues.apache.org/jira/browse/AMQ-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14191583#comment-14191583 \
] 

Igor Samardzija commented on AMQ-5322:
--------------------------------------

When I tried solution described at \
http://scott.cranton.com/2010/09/activemq-message-groups.html it is working. I do not \
understand why configuration via xml and java code are not the same!?

Log with updated activemq.xml configuration:
[09:26:24.115] DEBUG [main] (Producer.java:52) - Sending 3 messages in 1025 groups
[09:26:24.535] DEBUG [main] (Producer.java:65) - Total messages sent: 3075
[09:26:27.536] DEBUG [main] (Consumer.java:77) - received messages per consumer: 342
[09:26:27.536] DEBUG [main] (Consumer.java:77) - received messages per consumer: 342
[09:26:27.536] DEBUG [main] (Consumer.java:77) - received messages per consumer: 341
[09:26:27.536] DEBUG [main] (Consumer.java:82) - received total messages: 1025
[09:26:27.536] DEBUG [main] (Consumer.java:84) - dataCounter (total messages): 3075
[09:26:27.536] DEBUG [main] (Consumer.java:85) - missfires: 0

> Message is assigned to different client with the same JMSXGroupID
> -----------------------------------------------------------------
> 
> Key: AMQ-5322
> URL: https://issues.apache.org/jira/browse/AMQ-5322
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.9.0, 5.9.1, 5.10.0
> Reporter: wesley lin
> Attachments: AMQ5322Test.java, Consumer.java, GroupIdTest.java, Producer.java, \
> TestGroups.java 
> 
> I discovered since AMQ 5.9, message could be sent to different consumer even with \
> JMSXGroupID is set. Here is how to reproduce.
> 1. start 10 consumers to connect to server (consumer 1-10)
> 2. send 1025 messages with JMSXGroupID set from 0 - 1024 
> 3. add other 10 consumers to connect to server (consumer 11-20)
> 4. send several messages with JMSXGroup set from 0 - 1024
> Now, you can observe consumers added lately ( 11 - 20 ) will also receive messages \
> even JMSXGroupID have been dispatched to first consumer group( 1 - 10). 
> note:  In step2 , there should have more than 1024 different kind of JMSXGroupID to \
> reproduce this bug.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[prev in list] [next in list] [prev in thread] [next in thread]