[rocketmq-connect] 10/10: Add 'connectors/rocketmq-connect-activemq/' from commit 'e8aedf31c7eb4b26a2d9df7c766427fdfd845e9f'

[zh...@apache.org]

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 08fb7050d0a9709b07f722bbbaea601d2ac4c3b7
Merge: 0e15ffa e8aedf3
Author: odbozhou <87...@qq.com>
AuthorDate: Wed Mar 2 14:13:16 2022 +0800

    Add 'connectors/rocketmq-connect-activemq/' from commit 'e8aedf31c7eb4b26a2d9df7c766427fdfd845e9f'
    
    git-subtree-dir: connectors/rocketmq-connect-activemq
    git-subtree-mainline: 0e15ffa030cceae05ed4517289b2df09daa5fc48
    git-subtree-split: e8aedf31c7eb4b26a2d9df7c766427fdfd845e9f

 connectors/rocketmq-connect-activemq/README-CN.md  |  16 ++
 connectors/rocketmq-connect-activemq/README.md     |  16 ++
 connectors/rocketmq-connect-activemq/pom.xml       | 201 +++++++++++++++++++++
 .../apache/rocketmq/connect/activemq/Config.java   | 163 +++++++++++++++++
 .../rocketmq/connect/activemq/ErrorCode.java       |   8 +
 .../rocketmq/connect/activemq/Replicator.java      |  63 +++++++
 .../connector/ActivemqSourceConnector.java         |  72 ++++++++
 .../activemq/connector/ActivemqSourceTask.java     | 141 +++++++++++++++
 .../connect/activemq/pattern/PatternProcessor.java |  89 +++++++++
 .../rocketmq/connect/activemq/ReplicatorTest.java  |  74 ++++++++
 .../activemq/connector/ActivemqConnectorTest.java  |  58 ++++++
 .../activemq/connector/ActivemqSourceTaskTest.java | 165 +++++++++++++++++
 12 files changed, 1066 insertions(+)

diff --cc connectors/rocketmq-connect-activemq/README-CN.md
index 0000000,be03683..be03683
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/README-CN.md
+++ b/connectors/rocketmq-connect-activemq/README-CN.md
diff --cc connectors/rocketmq-connect-activemq/README.md
index 0000000,e15149e..e15149e
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/README.md
+++ b/connectors/rocketmq-connect-activemq/README.md
diff --cc connectors/rocketmq-connect-activemq/pom.xml
index 0000000,ccb4118..ccb4118
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/pom.xml
+++ b/connectors/rocketmq-connect-activemq/pom.xml
diff --cc connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Config.java
index 0000000,30f898d..30f898d
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Config.java
+++ b/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Config.java
diff --cc connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/ErrorCode.java
index 0000000,de3b3f5..de3b3f5
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/ErrorCode.java
+++ b/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/ErrorCode.java
diff --cc connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Replicator.java
index 0000000,e0ebe12..e0ebe12
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Replicator.java
+++ b/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Replicator.java
diff --cc connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceConnector.java
index 0000000,7e6290b..7e6290b
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceConnector.java
+++ b/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceConnector.java
diff --cc connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTask.java
index 0000000,c009274..c009274
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTask.java
+++ b/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTask.java
diff --cc connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/pattern/PatternProcessor.java
index 0000000,6e39a7e..6e39a7e
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/pattern/PatternProcessor.java
+++ b/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/pattern/PatternProcessor.java
diff --cc connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/ReplicatorTest.java
index 0000000,b94237e..b94237e
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/ReplicatorTest.java
+++ b/connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/ReplicatorTest.java
diff --cc connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqConnectorTest.java
index 0000000,22b301c..22b301c
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqConnectorTest.java
+++ b/connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqConnectorTest.java
diff --cc connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTaskTest.java
index 0000000,a71050c..a71050c
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTaskTest.java
+++ b/connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTaskTest.java