Skip to content

Add ability for a user to set mqtt's quiescentTimeout for forceable shutdowns #10210

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 6 commits into from
Jul 21, 2025
+98 −29
Merged

Add ability for a user to set mqtt's quiescentTimeout for forceable shutdowns #10210

Changes from 1 commit
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
3d6c718
Add ability for a user to set mqtt's `quiescentTimeout` for forceable…
cppwfs Jul 17, 2025
03d3bfd
Move QUIESCENT_TIMEOUT constant to ClientManager
cppwfs Jul 18, 2025
7879938
Mqttv5PahoMessageDrivenChannelAdapter.disconnectForcibly needs to use…
cppwfs Jul 18, 2025
7d165c5
Apply quiescentTimeout attribute to AbstractMqttClientManager.
cppwfs Jul 18, 2025
bb3e09c
Update the whats new MQTT announcement
cppwfs Jul 21, 2025
fb5afec
Change what's new notes on mqtt changes to be brief
cppwfs Jul 21, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion src/reference/antora/modules/ROOT/pages/whats-new.adoc
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -48,4 +48,5 @@ Previously deprecated classes in the `spring-integation-hazelcast` module, such
[[x7.0-mqtt-changes]]
=== MQTT Changes

The `disconnectForcibly` method in `MqttPahoMessageDrivenChannelAdapter`, `Mqttv5PahoMessageDrivenChannelAdapter`, `Mqttv3ClientManager`, and `Mqttv5ClientManager` now supports `getQuiescentTimeout` in addition to the existing `disconnectCompletionTimeout`.
The `disconnectForcibly` method in `MqttPahoMessageDrivenChannelAdapter`, `Mqttv5PahoMessageDrivenChannelAdapter`, `Mqttv3ClientManager`, and `Mqttv5ClientManager` now expose the option to configure `quiescentTimeout`, which is available through the https://eclipse.dev/paho/files/javadoc/org/eclipse/paho/client/mqttv3/IMqttAsyncClient.html[IMqttAsyncClient] client.
See https://docs.spring.io/spring-integration/api/org/springframework/integration/mqtt/core/package-summary.html[MQTT Core Java Docs] for more information.