'ActiveMQ consumer timed out

We are facing problem of ActiveMQ consumer timedout for one of our Queue(ServiceResponses). This problem started to occur after a couple of days. Here are Queues information from one Node AMQ.

Number of Consumers for Response Queue either 0 or 1 and also Number of Pending Messages exist on this Queue and seem to grow with time.

JMSTemplate with connection pooling(jms-pool) is being used for send and receive. Here is the code snippet which sends to request queue and receive from response queue

  val out = mc.andThen { msg =>
    msg.setJMSType(mt.jmsType)
    msg.setJMSCorrelationID(correlationId)
    msg.setJMSReplyTo(responseQueue)
    msg
  }
  jmsTemplate.send(requestQueue, out)
  jmsTemplate.setReceiveTimeout(timeoutInMillies)
  val response = jmsTemplate.receiveSelected(responseQueue, s"JMSCorrelationID = '$correlationId'")

Timeout value is 5 seconds.

Client Connection Settings are:

spring.activemq.broker-url=failover:(ssl://HOST1:PORT?keepAlive=true&connectionTimeout=500&soTimeout=360000,ssl://HOST2:PORT?keepAlive=true&connectionTimeout=500&soTimeout=360000)?initialReconnectDelay=10&maxReconnectDelay=9000&randomize=true&timeout=1000&backup=false&priorityBackup=true

Does anyone has idea what could be the reason and how can we fix this problem?

Sources

This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.

Source: Stack Overflow

Solution	Source

'ActiveMQ consumer timed out

Sources

Related Questions