How can we get messages from an MQTT broker and put them into the ZeroMQ queue?

Question

I am trying to get messages from an MQTT broker and insert that messages into ZeroMQ. What do I need to do to connect an MQTT broker to ZeroMQ in java?

Answer 1

Basically what you need to do is merge together the MQTT subscriber code with a ZeroMQ sender in Java, such that when you receive a message from the MQTT queue, it gets transferred to the 0MQ for 0MQ listeners to receive.

I haven't used MQTT from Java, but a popular library seems to be Paho.

The 0MQ documentation and example code is excellent, and a Java example can be found here.