ich supports a timeout if the response is not arriving
> after X time.
>
> Also you can also use a processor / bean and write some code that
> waits for the message from MQTT and then adds that as the response on
> the Camel Message
>
> On Mon, Aug 12, 2019 at 11:12 AM Michael Zaug
Hi
I would like to implement a request/reply pattern for MQTT 3.1.1, which
does not support InOut exchange pattern. I have a constant topic for the
request and a constant topic for the response as follows:
// ROUTE DEFINITION START
rest()
.routeId("request")
.post("path")
.to("mqtt:reque
me log to verify it.
>>
>> [1]https://github.com/apache/camel/blob/24521870b81576b5caf9ff3951cff8a0c2c77ab2/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTEndpoint.java#L256-L263
>>
>> Willem Jiang
>>
>> Twitter: willemjiang
>> Weibo: 姜宁willem
>>
>> On Thu
;
>
> Willem Jiang
>
> Twitter: willemjiang
> Weibo: 姜宁willem
>
> On Wed, Aug 7, 2019 at 10:56 PM Michael Zaugg wrote:
>>
>> We're having difficulties with persistent clients (using
>> cleanSession=false). We would like to get messages that were
We're having difficulties with persistent clients (using
cleanSession=false). We would like to get messages that were sent while
our client was disconnected.
Steps to reproduce:
1. start route to create the initial subscription for the testclient
from("mqtt:bar?subscribeTopicName=testtopic&cleanSe
