This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 2200115 [IOTDB-340] Remove unnecessary getting data types from
MManager (#677)
add 217257c Update RocketMQ example with session API (#676)
No new revisions were added by this update.
Summary of changes:
example/rocketmq/pom.xml | 2 +-
example/rocketmq/readme.md | 14 +++-
.../java/org/apache/iotdb/rocketmq/Constant.java | 62 +++++++-------
.../apache/iotdb/rocketmq/RocketMQConsumer.java | 97 ++++++++++++++--------
.../apache/iotdb/rocketmq/RocketMQProducer.java | 1 +
.../main/java/org/apache/iotdb/rocketmq/Utils.java | 2 +-
6 files changed, 109 insertions(+), 69 deletions(-)
