AbstractMqttMessageHandler.publish(String, Object, Message)
DefaultMqttPahoClientFactory.setConnectionOptions(MqttConnectOptions)