[ 
https://issues.apache.org/jira/browse/ARTEMIS-5164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932186#comment-17932186
 ] 

jjmarin commented on ARTEMIS-5164:
----------------------------------

We are going to try to reproduce it, we don't know when it happens yet. This 
week we are going to load test our application, we are going to try to have a 
reproducible test.
To answer your questions, we are not using mirroring, nor priorities. Our 
consumers each wake up with their own connection and session.  The connection 
string : tcp://IP:port?reconnectAttempts=-1. Production is done from these 
consumers pointing to a PooledJms connection pool, with 
:(tcp://IP01:port,tcp://IP02:port,tcp://IP03:port)?reconnectAttempts=2;failoverAttempts=1;ha=true

If we can find a way to reproduce the scenario, we would be happy to have a 
live session.

> AMQ222225: Sending unexpected exception to the client.Message count failure
> ---------------------------------------------------------------------------
>
>                 Key: ARTEMIS-5164
>                 URL: https://issues.apache.org/jira/browse/ARTEMIS-5164
>             Project: ActiveMQ Artemis
>          Issue Type: Bug
>    Affects Versions: 2.35.0
>         Environment: <cluster-connections>
>          <cluster-connection name="mccon">
>         <connection-ttl>60000</connection-ttl>
>             <call-timeout>5000</call-timeout>
>             <retry-interval>500</retry-interval>
>             <retry-interval-multiplier>1.0</retry-interval-multiplier>
>             <max-retry-interval>5000</max-retry-interval>
>             <initial-connect-attempts>-1</initial-connect-attempts>
>             <reconnect-attempts>-1</reconnect-attempts>
>     <forward-when-no-consumers>false</forward-when-no-consumers>    
>             <connector-ref>artemis</connector-ref>
>             <message-load-balancing>ON_DEMAND</message-load-balancing>
>             <max-hops>1</max-hops>
>             <static-connectors>
>                <connector-ref>node0</connector-ref>
>                <connector-ref>node1</connector-ref>
>                <connector-ref>node2</connector-ref>
>  
>             </static-connectors>
>          </cluster-connection>
>       </cluster-connections>
>            Reporter: jjmarin
>            Assignee: Clebert Suconic
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 2.40.0
>
>         Attachments: ErrorConsumers1.PNG, ErrorConsumers2.PNG, artemis.log, 
> broker.xml
>
>          Time Spent: 20m
>  Remaining Estimate: 0h
>
> Testing by sending a lot of messages by brokers, about 200,000. We have 
> noticed that the count of messages in the queue is broken. When we finished 
> consuming messages the website showed us that we had 22 messages. We checked 
> if they were scheduled and using the Jolokia API. It told us that we had no 
> scheduled messages.
> Checking the log we see that there are 22 instances of 
> {{NullPointerException}} with:
> {noformat}
> WARN  [org.apache.activemq.artemis.core.server] AMQ222225: Sending unexpected 
> exception to the client
> java.lang.NullPointerException: Cannot invoke 
> "org.apache.activemq.artemis.core.server.MessageReference.getSequence()" 
> because "o1" is null
>     at 
> org.apache.activemq.artemis.core.server.impl.MessageReferenceImpl$MessageReferenceComparatorSequence.compare(MessageReferenceImpl.java:50)
>  ~[artemis-server-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.core.server.impl.MessageReferenceImpl$MessageReferenceComparatorSequence.compare(MessageReferenceImpl.java:42)
>  ~[artemis-server-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.utils.collections.LinkedListImpl.scanLeft(LinkedListImpl.java:286)
>  ~[artemis-commons-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.utils.collections.LinkedListImpl.addSorted(LinkedListImpl.java:248)
>  ~[artemis-commons-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.utils.collections.PriorityLinkedListImpl.addSorted(PriorityLinkedListImpl.java:93)
>  ~[artemis-commons-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.core.server.impl.QueueImpl.internalAddSorted(QueueImpl.java:3069)
>  ~[artemis-server-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.core.server.impl.QueueImpl.addSorted(QueueImpl.java:1180)
>  ~[artemis-server-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.core.server.impl.QueueImpl.addSorted(QueueImpl.java:1215)
>  ~[artemis-server-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.core.server.impl.QueueImpl.postRollback(QueueImpl.java:4247)
>  ~[artemis-server-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.core.server.impl.RefsOperation.afterRollback(RefsOperation.java:131)
>  ~[artemis-server-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.core.transaction.impl.TransactionImpl.afterRollback(TransactionImpl.java:600)
>  ~[artemis-server-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.core.transaction.impl.TransactionImpl$4.done(TransactionImpl.java:436)
>  ~[artemis-server-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.core.persistence.impl.journal.OperationContextImpl.executeOnCompletion(OperationContextImpl.java:226)
>  ~[artemis-server-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.core.persistence.impl.journal.OperationContextImpl.executeOnCompletion(OperationContextImpl.java:168)
>  ~[artemis-server-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.core.persistence.impl.journal.AbstractJournalStorageManager.afterCompleteOperations(AbstractJournalStorageManager.java:352)
>  ~[artemis-server-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.core.transaction.impl.TransactionImpl.internalRollback(TransactionImpl.java:427)
>  ~[artemis-server-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.core.transaction.impl.TransactionImpl.rollback(TransactionImpl.java:400)
>  ~[artemis-server-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.close(ServerConsumerImpl.java:594)
>  ~[artemis-server-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.core.server.impl.ServerSessionImpl.closeConsumer(ServerSessionImpl.java:1765)
>  ~[artemis-server-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.core.protocol.core.ServerSessionPacketHandler.slowPacketHandler(ServerSessionPacketHandler.java:627)
>  ~[artemis-server-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.core.protocol.core.ServerSessionPacketHandler.onMessagePacket(ServerSessionPacketHandler.java:319)
>  ~[artemis-server-2.35.0.jar:2.35.0]
>     at org.apache.activemq.artemis.utils.actors.Actor.doTask(Actor.java:32) 
> ~[artemis-commons-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:68)
>  ~[artemis-commons-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:57)
>  ~[artemis-commons-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:32)
>  ~[artemis-commons-2.35.0.jar:2.35.0]
>     at 
> org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:68)
>  ~[artemis-commons-2.35.0.jar:2.35.0]
>     at 
> java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
>  [?:?]
>     at 
> java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
>  [?:?]
>     at 
> org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118)
>  [artemis-commons-2.35.0.jar:2.35.0]{noformat}
> We understand that this is related and we haven't found out why it happens. 
> Any ideas?
>  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact


Reply via email to