rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/MQTTBridge.java (5 lines): - line 92: // TODO qos 1/2 PUBLISH - line 93: // TODO qos 1: PUBACK - line 94: // TODO qos 2: PUBREC - line 95: // TODO qos 2: PUBREL - line 96: // TODO qos 2: PUBCOMP rocketmq-iot-bridge/style/rmq_checkstyle.xml (2 lines): - line 48: - line 53: rocketmq-jms/style/rmq_checkstyle.xml (2 lines): - line 42: - line 47: rocketmq-redis/style/rmq_checkstyle.xml (2 lines): - line 42: - line 47: rocketmq-serializer/style/rmq_checkstyle.xml (2 lines): - line 42: - line 47: rocketmq-hbase/style/rmq_checkstyle.xml (2 lines): - line 42: - line 47: rocketmq-flume/style/rmq_checkstyle.xml (2 lines): - line 42: - line 47: rocketmq-mysql/style/rmq_checkstyle.xml (2 lines): - line 42: - line 47: rocketmq-spark/style/rmq_checkstyle.xml (2 lines): - line 42: - line 47: rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/protocol/mqtt/handler/downstream/impl/MqttDisconnectMessageHandler.java (1 line): - line 43: // TODO discard the Will Message and Will Topic rocketmq-knative/source/pkg/client/informers/externalversions/generic.go (1 line): - line 53: // TODO extend this to unknown resources with a client pool rocketmq-knative/source/pkg/reconciler/rocketmqsource.go (1 line): - line 185: // TODO this is only needed by the fake client. Real K8s does not need it. Remove it once rocketmq-spark/src/main/java/org/apache/rocketmq/spark/streaming/RocketMQReceiver.java (1 line): - line 98: // TODO add retry rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/protocol/mqtt/handler/MqttConnectionHandler.java (1 line): - line 87: // TODO support Sticky Session rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/protocol/mqtt/handler/downstream/impl/MqttPubackMessageHandler.java (1 line): - line 46: // TODO: remove the message from the published in-flight message rocketmq-spark/src/main/scala/org/apache/spark/streaming/MQPullInputDStream.scala (1 line): - line 104: // TODO should not persist here if autoCommit is off