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