[jboss-jira] [JBoss JIRA] (WFLY-5795) HA JMS Topic Subscriber of Colocated life backup symmetrical 2 nodes cluster violates Publish-Subscribe pattern.
Michal Sudra (JIRA)
issues at jboss.org
Fri Feb 26 09:29:00 EST 2016
[ https://issues.jboss.org/browse/WFLY-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13168991#comment-13168991 ]
Michal Sudra edited comment on WFLY-5795 at 2/26/16 9:28 AM:
-------------------------------------------------------------
I've re-run the tests on my environment with the latest WildFly 10.0.0.Final release and problem still appears.
{code:java}
Sent message: This is text message 0
Sent message: This is text message 1
Sent message: This is text message 2
Sent message: This is text message 3
Sent message: This is text message 4
Sent message: This is text message 5
Sent message: This is text message 6
Sent message: This is text message 7
Sent message: This is text message 8
Sent message: This is text message 9
0 Recieved message: This is text message 0 from node 0 from jms/topic/ClusterStateTopic
1 Recieved message: This is text message 2 from node 0 from jms/topic/ClusterStateTopic
2 Recieved message: This is text message 4 from node 0 from jms/topic/ClusterStateTopic
3 Recieved message: This is text message 6 from node 0 from jms/topic/ClusterStateTopic
4 Recieved message: This is text message 8 from node 0 from jms/topic/ClusterStateTopic
5 error receiving message from node 0
6 error receiving message from node 0
7 error receiving message from node 0
8 error receiving message from node 0
9 error receiving message from node 0
0 Recieved message: This is text message 0 from node 1 from jms/topic/ClusterStateTopic
1 Recieved message: This is text message 1 from node 1 from jms/topic/ClusterStateTopic
2 Recieved message: This is text message 2 from node 1 from jms/topic/ClusterStateTopic
3 Recieved message: This is text message 3 from node 1 from jms/topic/ClusterStateTopic
4 Recieved message: This is text message 4 from node 1 from jms/topic/ClusterStateTopic
5 Recieved message: This is text message 5 from node 1 from jms/topic/ClusterStateTopic
6 Recieved message: This is text message 6 from node 1 from jms/topic/ClusterStateTopic
7 Recieved message: This is text message 7 from node 1 from jms/topic/ClusterStateTopic
8 Recieved message: This is text message 8 from node 1 from jms/topic/ClusterStateTopic
9 Recieved message: This is text message 9 from node 1 from jms/topic/ClusterStateTopic
example complete
#####################
### SUCCESS! ###
#####################
{code}
I've attached the output log files for both WildFly instances of my domain - master and slave.
It seems that for every message that was not delivered to receiver on node 0, there is an warning entry in the slave.log file with message:
{code:java}
[org.apache.activemq.artemis.core.server] (default I/O-1) AMQ222196: Could not find binding with id=51 on routeFromCluster for message=ServerMessage[messageID=88,durable=true,userID=e28f3fe3-dc93-11e5-a855-d7d7c9cb596b,priority=4, bodySize=392, timestamp=Fri Feb 26 14:19:02 UTC 2016,expiration=0, durable=true, address=jms.topic.ClusterStateTopic,properties=TypedProperties[__AMQ_CID=e08f2a14-dc93-11e5-a855-d7d7c9cb596b]]@88941223 binding = BindingsImpl [name=jms.topic.ClusterStateTopic]
{code}
was (Author: msudra):
I've re-run the tests on my environment with the latest WildFly 10.0.0.Final release and problem still appears.
{code:java}
Sent message: This is text message 0
Sent message: This is text message 1
Sent message: This is text message 2
Sent message: This is text message 3
Sent message: This is text message 4
Sent message: This is text message 5
Sent message: This is text message 6
Sent message: This is text message 7
Sent message: This is text message 8
Sent message: This is text message 9
0 Recieved message: This is text message 0 from node 0 from jms/topic/ClusterStateTopic
1 Recieved message: This is text message 2 from node 0 from jms/topic/ClusterStateTopic
2 Recieved message: This is text message 4 from node 0 from jms/topic/ClusterStateTopic
3 Recieved message: This is text message 6 from node 0 from jms/topic/ClusterStateTopic
4 Recieved message: This is text message 8 from node 0 from jms/topic/ClusterStateTopic
5 error receiving message from node 0
6 error receiving message from node 0
7 error receiving message from node 0
8 error receiving message from node 0
9 error receiving message from node 0
0 Recieved message: This is text message 0 from node 1 from jms/topic/ClusterStateTopic
1 Recieved message: This is text message 1 from node 1 from jms/topic/ClusterStateTopic
2 Recieved message: This is text message 2 from node 1 from jms/topic/ClusterStateTopic
3 Recieved message: This is text message 3 from node 1 from jms/topic/ClusterStateTopic
4 Recieved message: This is text message 4 from node 1 from jms/topic/ClusterStateTopic
5 Recieved message: This is text message 5 from node 1 from jms/topic/ClusterStateTopic
6 Recieved message: This is text message 6 from node 1 from jms/topic/ClusterStateTopic
7 Recieved message: This is text message 7 from node 1 from jms/topic/ClusterStateTopic
8 Recieved message: This is text message 8 from node 1 from jms/topic/ClusterStateTopic
9 Recieved message: This is text message 9 from node 1 from jms/topic/ClusterStateTopic
example complete
#####################
### SUCCESS! ###
#####################
{code}
I've attached the output log files for both WildFly instances of my domain - master and slave.
> HA JMS Topic Subscriber of Colocated life backup symmetrical 2 nodes cluster violates Publish-Subscribe pattern.
> ----------------------------------------------------------------------------------------------------------------
>
> Key: WFLY-5795
> URL: https://issues.jboss.org/browse/WFLY-5795
> Project: WildFly
> Issue Type: Bug
> Components: JMS
> Affects Versions: 10.0.0.CR4
> Environment: 2 node symmetrical colocated life backup cluster (domain mode). Configuration (domain.xml, host.xml) provided as attachment.
> Reporter: Michal Sudra
> Assignee: Jeff Mesnil
> Priority: Critical
> Fix For: 10.0.0.Final
>
> Attachments: ClusteredTopicTest.java, domain.xml, host-slave.xml, host.xml, master.log, slave.log
>
>
> Test Client is producing 10 messages on topic on node 1 and 2 consumers connected to node 1 and the other to node 2 are then consuming the messages.
> Expectation: Every consumer receives 10 Messages.
> Result of test: Consumer connected to node 1 is only getting every second message. Consumer connected to node 2 is receiving all 10 messages:
> Output of test program:
> Sent message: This is text message 0
> Sent message: This is text message 1
> Sent message: This is text message 2
> Sent message: This is text message 3
> Sent message: This is text message 4
> Sent message: This is text message 5
> Sent message: This is text message 6
> Sent message: This is text message 7
> Sent message: This is text message 8
> Sent message: This is text message 9
> 0 Recieved message: This is text message 0 from node 0 from java:/jms/topic/ClusterStateTopic
> 1 Recieved message: This is text message 2 from node 0 from java:/jms/topic/ClusterStateTopic
> 2 Recieved message: This is text message 4 from node 0 from java:/jms/topic/ClusterStateTopic
> 3 Recieved message: This is text message 6 from node 0 from java:/jms/topic/ClusterStateTopic
> 4 Recieved message: This is text message 8 from node 0 from java:/jms/topic/ClusterStateTopic
> 5 error receiving message from node 0
> 6 error receiving message from node 0
> 7 error receiving message from node 0
> 8 error receiving message from node 0
> 9 error receiving message from node 0
> 0 Recieved message: This is text message 0 from node 1 from java:/jms/topic/ClusterStateTopic
> 1 Recieved message: This is text message 1 from node 1 from java:/jms/topic/ClusterStateTopic
> 2 Recieved message: This is text message 2 from node 1 from java:/jms/topic/ClusterStateTopic
> 3 Recieved message: This is text message 3 from node 1 from java:/jms/topic/ClusterStateTopic
> 4 Recieved message: This is text message 4 from node 1 from java:/jms/topic/ClusterStateTopic
> 5 Recieved message: This is text message 5 from node 1 from java:/jms/topic/ClusterStateTopic
> 6 Recieved message: This is text message 6 from node 1 from java:/jms/topic/ClusterStateTopic
> 7 Recieved message: This is text message 7 from node 1 from java:/jms/topic/ClusterStateTopic
> 8 Recieved message: This is text message 8 from node 1 from java:/jms/topic/ClusterStateTopic
> 9 Recieved message: This is text message 9 from node 1 from java:/jms/topic/ClusterStateTopic
> The test program is added and the 2 node names are given as parameters for main.
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
More information about the jboss-jira
mailing list