You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by Mariusz Koprowski <Ma...@hexagonmining.com> on 2017/06/12 15:55:48 UTC

MQTT to MQTT

Hi All
I need to build a simple component that will take messages from one MQTT topic and republish it on other MQTT topic (from one broker to another broker). Messages are binary so I can't add anything to the body of the message.
The main questions are

  1.  how to effectively store topics mapping (can I use LeveDB?)
  2.  how to make it dynamic (e.g. can I put data dynamically to LevelDB and they will be used across all routes ?)

Example
Incoming messages comes on topics xx/xx/xx and in zz/zz/zz
All of the messages from both of that topics have to by published on topic yyy/yyy

Ther is no splitting of the topic so there will not be an example where on topic should go to two topics

Thanks for help


Best regards
--
Mariusz Koprowski