-
Bug
-
Resolution: Done
-
Blocker
-
7.1.0.DR14, 7.1.0.DR15, 7.1.0.DR16, 7.1.0.DR18, 7.1.0.DR19, 7.1.0.ER1
We have test which does 10 times failover/failback in shared store HA scenario to be 100% sure that HA is robust. The test at first send 50 000 messages. During sending there is no crash of server. After that there is sequence of 10 kills and restarts of server 1 which is doing during receiving of messages.
Since server 1 has backup, receiver should receive all messages even server 1 crashes. However sometimes happens that receiver starts getting error AMQ119027: Could not find reference on consumer ID=0 on all attempts to commit messages. After several attempts to again receive bulk of messages and commit them, receive method returns NULL and receiver finishes before time.
Customer impact: In some certain cases receiver is not able to do failover/failback and it returns NULL even there are messages to consume.
This is regression against EAP 7.0.z.
03:19:10,910 Thread-704 ERROR [org.jboss.qa.hornetq.apps.clients.Receiver11:148] RETRY receive for host: 127.0.0.1, Trying to receive message with count: 19728 javax.jms.IllegalStateException: AMQ119027: Could not find reference on consumer ID=0, messageId = 77,698 queue = jms.queue.testQueue0 at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:407) at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:318) at org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQSessionContext.sendACK(ActiveMQSessionContext.java:487) at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.acknowledge(ClientSessionImpl.java:746) at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.doAck(ClientConsumerImpl.java:1105) at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.acknowledge(ClientConsumerImpl.java:764) at org.apache.activemq.artemis.core.client.impl.ClientMessageImpl.acknowledge(ClientMessageImpl.java:96) at org.apache.activemq.artemis.core.client.impl.ClientMessageImpl.acknowledge(ClientMessageImpl.java:38) at org.apache.activemq.artemis.jms.client.ActiveMQMessageConsumer.getMessage(ActiveMQMessageConsumer.java:241) at org.apache.activemq.artemis.jms.client.ActiveMQMessageConsumer.receive(ActiveMQMessageConsumer.java:132) at org.jboss.qa.hornetq.apps.clients.Receiver11.receiveMessage(Receiver11.java:140) at org.jboss.qa.hornetq.apps.clients.ReceiverTransAck.run(ReceiverTransAck.java:83) Caused by: ActiveMQIllegalStateException[errorType=ILLEGAL_STATE message=AMQ119027: Could not find reference on consumer ID=0, messageId = 77,698 queue = jms.queue.testQueue0] ... 12 more 03:19:10,930 Thread-704 ERROR [org.jboss.qa.hornetq.apps.clients.Receiver11:55] Receiver - COMMIT FAILED - JMSException thrown during commit: AMQ119027: Could not find reference on consumer ID=0, messageId = 77 ,670 queue = jms.queue.testQueue0. Receiver for node: 127.0.0.1. Received message - count: 19728, retrying receive javax.jms.IllegalStateException: AMQ119027: Could not find reference on consumer ID=0, messageId = 77,670 queue = jms.queue.testQueue0 at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:407) at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:318) at org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQSessionContext.sendACK(ActiveMQSessionContext.java:487) at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.acknowledge(ClientSessionImpl.java:746) at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.doAck(ClientConsumerImpl.java:1105) at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.flushAcks(ClientConsumerImpl.java:789) at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.flushAcks(ClientSessionImpl.java:1646) at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.rollback(ClientSessionImpl.java:564) at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.rollback(ClientSessionImpl.java:538) at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.rollbackOnFailover(ClientSessionImpl.java:472) at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.commit(ClientSessionImpl.java:493) at org.apache.activemq.artemis.jms.client.ActiveMQSession.commit(ActiveMQSession.java:218) at org.jboss.qa.hornetq.apps.clients.Receiver11.commitSession(Receiver11.java:39) at org.jboss.qa.hornetq.apps.clients.ReceiverTransAck.run(ReceiverTransAck.java:103) Caused by: ActiveMQIllegalStateException[errorType=ILLEGAL_STATE message=AMQ119027: Could not find reference on consumer ID=0, messageId = 77,670 queue = jms.queue.testQueue0] ... 14 more
- is blocked by
-
JBEAP-12044 Upgrade Artemis 1.5.5.jbossorg-006
- Closed
- is incorporated by
-
JBEAP-12044 Upgrade Artemis 1.5.5.jbossorg-006
- Closed
- is related to
-
ENTMQBR-607 Lost messages in cluster with server crashes
- Closed