Issue #1: Initial implementation for MQTT operators in Java.