Clean up - renamed operators to MQTTSource and MQTTSink to match
existing names.