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 03:23:11 UTC
[rocketmq-connect] 03/03: Add 'connector/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 5feab9cd053c7fa6b7b64cfeac5af860f58bd725
Merge: 232c585 a7ab1c4
Author: odbozhou <87...@qq.com>
AuthorDate: Wed Mar 2 11:22:43 2022 +0800

    Add 'connector/rocketmq-connect-rabbitmq/' from commit 'a7ab1c46a9938df2984c3ad730609c1a7797cc9b'
    
    git-subtree-dir: connector/rocketmq-connect-rabbitmq
    git-subtree-mainline: 232c585fdee7e6a0ab6d7aef04140019bc9a3be7
    git-subtree-split: a7ab1c46a9938df2984c3ad730609c1a7797cc9b

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