Connection amqp = createAmqpConnection();
Session session = amqp.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageConsumer consumer = session.createConsumer(session.createTopic("topic://FOO"));
final BlockingConnection mqtt = createMQTTConnection().blockingConnection();
mqtt.connect();
byte[] payload = bytes("Hello World");
mqtt.publish("FOO", payload, QoS.AT_LEAST_ONCE, false);
mqtt.disconnect();
Message msg = consumer.receive(1000 * 5);