Skip to content

Commit 5688abc

Browse files
committed
Adding Documentation for MqttPahoMessageDrivenChannelAdapter and Mqttv5PahoMessageDrivenChannelAdapter
1 parent e3629e7 commit 5688abc

File tree

2 files changed

+23
-1
lines changed

2 files changed

+23
-1
lines changed

src/reference/antora/modules/ROOT/pages/mqtt.adoc

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -548,3 +548,19 @@ public IntegrationFlow mqttOutFlow(
548548
return f -> f.handle(new Mqttv5PahoMessageHandler(clientManager));
549549
}
550550
----
551+
552+
NOTE: Starting with version 6.4, multiple instances of `MqttPahoMessageDrivenChannelAdapter` and `Mqttv5PahoMessageDrivenChannelAdapter` can now be added at runtime using corresponding `ClientManager` through `IntegrationFlowContext`
553+
554+
[source,java]
555+
----
556+
private void addAddRuntimeAdapter(IntegrationFlowContext flowContext,Mqttv5ClientManager clientManager,
557+
String topic,MessageChannel channel){
558+
flowContext
559+
.registration(
560+
IntegrationFlow
561+
.from(new Mqttv5PahoMessageDrivenChannelAdapter(clientManager, topic))
562+
.channel(channel)
563+
.get())
564+
.register();
565+
}
566+
----

src/reference/antora/modules/ROOT/pages/whats-new.adoc

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,4 +59,10 @@ See xref:redis.adoc[Redis Support] for more information.
5959
=== Groovy Changes
6060

6161
The `ControlBusFactoryBean` (and respective `<int-groovy:control-bus>` XML tag) has been deprecated (for removal) in favor of new introduced `ControlBusFactoryBean` based on a new model implemented in the `ControlBusCommandRegistry`.
62-
See xref:control-bus.adoc[Control Bus] for more information.
62+
See xref:control-bus.adoc[Control Bus] for more information.
63+
64+
[[x6.4-mqtt-changes]]
65+
=== mqtt Changes
66+
67+
Multiple instances of `MqttPahoMessageDrivenChannelAdapter` and `Mqttv5PahoMessageDrivenChannelAdapter` can now be added at runtime using corresponding `ClientManager` through `IntegrationFlowContext`
68+
See xref:mqtt.adoc[MQTT Support] for more information.

0 commit comments

Comments
 (0)