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 <[email protected]> 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
