You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2022/03/02 06:15:05 UTC
[rocketmq-connect] 07/10: Add 'connectors/rocketmq-connect-rabbitmq/' from commit 'a7ab1c46a9938df2984c3ad730609c1a7797cc9b'

This is an automated email from the ASF dual-hosted git repository.

zhoubo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git

commit 3f900aab003d00885c97adfbbf8fb3aa9f8e3835
Merge: d0bd4f0 a7ab1c4
Author: odbozhou <87...@qq.com>
AuthorDate: Wed Mar 2 14:12:19 2022 +0800

    Add 'connectors/rocketmq-connect-rabbitmq/' from commit 'a7ab1c46a9938df2984c3ad730609c1a7797cc9b'
    
    git-subtree-dir: connectors/rocketmq-connect-rabbitmq
    git-subtree-mainline: d0bd4f085dce5a8bfa393e953ed14781ccb73e82
    git-subtree-split: a7ab1c46a9938df2984c3ad730609c1a7797cc9b

 connectors/rocketmq-connect-rabbitmq/README.md     |  17 ++
 connectors/rocketmq-connect-rabbitmq/pom.xml       | 205 +++++++++++++++++++++
 .../rocketmq/connect/rabbitmq/ErrorCode.java       |   8 +
 .../rocketmq/connect/rabbitmq/RabbitmqConfig.java  |  61 ++++++
 .../connector/RabbitmqSourceConnector.java         |  35 ++++
 .../rabbitmq/connector/RabbitmqSourceTask.java     |  37 ++++
 .../rabbitmq/pattern/RabbitMQPatternProcessor.java |  48 +++++
 .../rocketmq/connect/jms/RabbitmqConfigTest.java   |  28 +++
 .../connector/RabbitmqSourceConnectorTest.java     |  54 ++++++
 .../rabbitmq/connector/RabbitmqSourceTaskTest.java | 164 +++++++++++++++++
 .../pattern/RabbitMQPatternProcessorTest.java      |  41 +++++
 11 files changed, 698 insertions(+)

diff --cc connectors/rocketmq-connect-rabbitmq/README.md
index 0000000,708bee3..708bee3
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-rabbitmq/README.md
+++ b/connectors/rocketmq-connect-rabbitmq/README.md
diff --cc connectors/rocketmq-connect-rabbitmq/pom.xml
index 0000000,d5687c1..d5687c1
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-rabbitmq/pom.xml
+++ b/connectors/rocketmq-connect-rabbitmq/pom.xml
diff --cc connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/ErrorCode.java
index 0000000,5f70361..5f70361
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/ErrorCode.java
+++ b/connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/ErrorCode.java
diff --cc connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/RabbitmqConfig.java
index 0000000,2b12c18..2b12c18
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/RabbitmqConfig.java
+++ b/connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/RabbitmqConfig.java
diff --cc connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceConnector.java
index 0000000,328632d..328632d
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceConnector.java
+++ b/connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceConnector.java
diff --cc connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceTask.java
index 0000000,ab2d1e4..ab2d1e4
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceTask.java
+++ b/connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceTask.java
diff --cc connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/pattern/RabbitMQPatternProcessor.java
index 0000000,5056a11..5056a11
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/pattern/RabbitMQPatternProcessor.java
+++ b/connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/pattern/RabbitMQPatternProcessor.java
diff --cc connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/jms/RabbitmqConfigTest.java
index 0000000,7228f68..7228f68
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/jms/RabbitmqConfigTest.java
+++ b/connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/jms/RabbitmqConfigTest.java
diff --cc connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceConnectorTest.java
index 0000000,ea52a43..ea52a43
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceConnectorTest.java
+++ b/connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceConnectorTest.java
diff --cc connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceTaskTest.java
index 0000000,232ddc1..232ddc1
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceTaskTest.java
+++ b/connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceTaskTest.java
diff --cc connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/pattern/RabbitMQPatternProcessorTest.java
index 0000000,a23d233..a23d233
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/pattern/RabbitMQPatternProcessorTest.java
+++ b/connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/pattern/RabbitMQPatternProcessorTest.java