1 Reply Latest reply on May 22, 2014 6:20 PM by stuarthalloway

    how to handle resetIfSlowConsumer interruption?

    stuarthalloway

      We are seeing a (so far difficult to reproduce) scenario where a consumer receive fails due to interruption:

      org.hornetq.api.core.HornetQInterruptedException: java.lang.InterruptedException
              at org.hornetq.core.client.impl.ClientConsumerImpl.resetIfSlowConsumer(ClientConsumerImpl.java:971) ~[hornetq-core-client-2.3.17.Final.jar:na]
              at org.hornetq.core.client.impl.ClientConsumerImpl.receive(ClientConsumerImpl.java:384) ~[hornetq-core-client-2.3.17.Final.jar:na]
              at org.hornetq.core.client.impl.ClientConsumerImpl.receive(ClientConsumerImpl.java:409) ~[hornetq-core-client-2.3.17.Final.jar:na]
      

      Once this occurs, the consumer appears to have been closed, with subsequent receives triggering:

      org.hornetq.api.core.HornetQObjectClosedException: HQ119017: Consumer is closed
              at org.hornetq.core.client.impl.ClientConsumerImpl.checkClosed(ClientConsumerImpl.java:1045) ~[hornetq-core-client-2.3.17.Final.jar:na]
              at org.hornetq.core.client.impl.ClientConsumerImpl.receive(ClientConsumerImpl.java:192) ~[hornetq-core-client-2.3.17.Final.jar:na]
              at org.hornetq.core.client.impl.ClientConsumerImpl.receive(ClientConsumerImpl.java:409) ~[hornetq-core-client-2.3.17.Final.jar:na]
      

      What should a well-behaved program do when it sees a HornetQInterruptedException bubble up from resetIfSlowConsumer?

      What are the possible causes of this interruption, and how might I avoid them?