diff --git a/src/reference/antora/modules/ROOT/pages/mqtt.adoc b/src/reference/antora/modules/ROOT/pages/mqtt.adoc index bbad0a567c6..4bebcc64448 100644 --- a/src/reference/antora/modules/ROOT/pages/mqtt.adoc +++ b/src/reference/antora/modules/ROOT/pages/mqtt.adoc @@ -237,7 +237,7 @@ public class MqttJavaApplication { public IntegrationFlow mqttInbound() { return IntegrationFlow.from( new MqttPahoMessageDrivenChannelAdapter("tcp://localhost:1883", - "testClient", "topic1", "topic2");) + "testClient", "topic1", "topic2")) .handle(m -> System.out.println(m.getPayload())) .get(); }