[
https://issues.apache.org/jira/browse/CAMEL-24523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinyu Chen updated CAMEL-24523:
-------------------------------
Description:
When automaticReconnect=true and the MQTT broker reconnects, if the
post-reconnect subscribe() call fails (e.g., broker does not send SUBACK,
causing MqttException 32000 after keepAlive timeout), the consumer only logs
the error at ERROR level but takes no recovery action. The route remains in
Started state while silently consuming no messages (zombie state).
This is the MQTT3 counterpart of CAMEL-24511 (camel-paho-mqtt5). The same gap
exists in PahoConsumer.connectComplete(). However, this component has been
deprecated since 4.21 as the underlying Paho mqtt3 client has had no new
release since 2020. Users are encouraged to migrate to camel-paho-mqtt5.
was:
When automaticReconnect=true and the MQTT broker reconnects, if the
post-reconnect subscribe() call fails (e.g., broker does not send SUBACK,
causing MqttException 32000 after keepAlive timeout), the consumer only logs
the error at ERROR level but takes no recovery action. The route remains in
Started state while silently consuming no messages (zombie state).
This is the MQTT3 counterpart of CAMEL-24511 (camel-paho-mqtt5). The same gap
exists in PahoConsumer.connectComplete().
> camel-paho - Consumer silently stops receiving messages when resubscribe
> fails and route remains in Started state
> -----------------------------------------------------------------------------------------------------------------
>
> Key: CAMEL-24523
> URL: https://issues.apache.org/jira/browse/CAMEL-24523
> Project: Camel
> Issue Type: Bug
> Components: camel-paho
> Reporter: Jinyu Chen
> Assignee: Jinyu Chen
> Priority: Major
>
> When automaticReconnect=true and the MQTT broker reconnects, if the
> post-reconnect subscribe() call fails (e.g., broker does not send SUBACK,
> causing MqttException 32000 after keepAlive timeout), the consumer only logs
> the error at ERROR level but takes no recovery action. The route remains in
> Started state while silently consuming no messages (zombie state).
> This is the MQTT3 counterpart of CAMEL-24511 (camel-paho-mqtt5). The same gap
> exists in PahoConsumer.connectComplete(). However, this component has been
> deprecated since 4.21 as the underlying Paho mqtt3 client has had no new
> release since 2020. Users are encouraged to migrate to camel-paho-mqtt5.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
