Block Rest Request Until Message Arrives On Other Route

[Michael Zaugg]

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:requestTopic")
// wait for reply on another route (aggregate?, enrich?)
  .endRest

from("mqtt:responseTopic")
.to("notify routeId request")

// ROUTE DEFINITION END

neither aggregate() nor enrich() are blocking. Therefore the rest call
terminates before the response arrives.

Any advice would be highly appreciated