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/iotdb.git.
from a41c855 Fix the CI issue introduced by thrift0.14 and the thrift
server is not closed properly in SessionPoolTest. (#3198)
add 222396c add rabbitmq example module. (#3049)
No new revisions were added by this update.
Summary of changes:
example/pom.xml | 6 +
example/{pulsar => rabbitmq}/pom.xml | 20 ++--
example/rabbitmq/readme.md | 63 ++++++++++
.../java/org/apache/iotdb/rabbitmq}/Constant.java | 25 ++--
.../iotdb/rabbitmq/RabbitMQChannelUtils.java | 49 ++++++++
.../apache/iotdb/rabbitmq/RabbitMQConsumer.java | 132 +++++++++++++++++++++
.../apache/iotdb/rabbitmq/RabbitMQProducer.java | 49 ++++++++
7 files changed, 324 insertions(+), 20 deletions(-)
copy example/{pulsar => rabbitmq}/pom.xml (81%)
create mode 100644 example/rabbitmq/readme.md
copy example/{rocketmq/src/main/java/org/apache/iotdb/rocketmq =>
rabbitmq/src/main/java/org/apache/iotdb/rabbitmq}/Constant.java (77%)
create mode 100644
example/rabbitmq/src/main/java/org/apache/iotdb/rabbitmq/RabbitMQChannelUtils.java
create mode 100644
example/rabbitmq/src/main/java/org/apache/iotdb/rabbitmq/RabbitMQConsumer.java
create mode 100644
example/rabbitmq/src/main/java/org/apache/iotdb/rabbitmq/RabbitMQProducer.java
