[CAMEL-19170] HealthCheck for ActiveMQ in Quarkus

• Type: Wish
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Component/s: camel-activemq

Environment

Quarkus Version: 2.16.1.Final

camel-quarkus-activemq: 2.16.0

• Estimated Complexity: Unknown
• Assignee: Unassigned
• Reporter: Romeo Köppel
• Created: 20/Mar/23 08:30
• Updated: 23/Mar/23 15:22

Description

Hi

Currently when the services has no connection to the ActiveMQ ....

Feb 17 17:14:06 XXXXXXXX[568839]: 2023-02-17T16:14:06.810Z ERROR trace_id= span_id= [org.apache.camel.component.jms.DefaultJmsMessageListenerContainer] (Camel (camel-1) thread #1 - JmsConsumer[XXXXXXXX]) Could not refresh JMS Connection for destination 'XXXXXXXX' - retrying using FixedBackOff{interval=5000, currentAttempts=1, maxAttempts=unlimited}. Cause: Could not connect to broker URL: tcp://localhost:61616. Reason: java.net.ConnectException: Connection refused

Feb 17 17:14:11 XXXXXXXX[568839]: 2023-02-17T16:14:11.813Z ERROR trace_id= span_id= [org.apache.camel.component.jms.DefaultJmsMessageListenerContainer] (Camel (camel-1) thread #1 - JmsConsumer[XXXXXXXX]) Could not refresh JMS Connection for destination 'XXXXXXXX' - retrying using FixedBackOff{interval=5000, currentAttempts=2, maxAttempts=unlimited}. Cause: Could not connect to broker URL: tcp://localhost:61616. Reason: java.net.ConnectException: Connection refused 

... the service is UP anyway:

{
    "status": "UP",
    "checks": [
        {
            "name": "Database connections health check",
            "status": "UP",
            "data": {
                "<default>": "UP"
            }
        },
        {
            "name": "camel-routes",
            "status": "UP"
        },
        {
            "name": "context",
            "status": "UP",
            "data": {
                "context.name": "camel-1",
                "context.phase": "5",
                "context.version": "3.19.0",
                "context.status": "Started",
                "check.kind": "READINESS"
            }
        },
        {
            "name": "camel-consumers",
            "status": "UP"
        }
    ]
} 

The reason for this is probably, that the JMS Consumer hasn't implemented a HealthCheck by default. I found this out within the ConsumerHealthCheck class in the doCallCheck method.

Because of this I had to implement a custom HealthCheck for ActiveMQ.

Is it possible that in the future a HealthCheck for ActiveMQ will be delivered by default?

Thanks a lot