Hi Yakov, I've had a few free cycles to fix the code style and Javadoc issues you reported in the MQTT Streamer and I've pushed my changes to branch ignite-1747.
Would you mind having a look to see if it adapts better now? Thanks, *Raúl Kripalani* PMC & Committer @ Apache Ignite, Apache Camel | Integration, Big Data and Messaging Engineer http://about.me/raulkripalani | http://www.linkedin.com/in/raulkripalani http://blog.raulkr.net | twitter: @raulvk