[rocketmq-connect] 12/12: Add 'connector/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 32a23ce18c3c6f4c3ab1e813702c9fd7e5ab329a
Merge: a1e5f60 e8aedf3
Author: odbozhou <87...@qq.com>
AuthorDate: Tue Mar 1 21:42:19 2022 +0800

    Add 'connector/rocketmq-connect-activemq/' from commit 'e8aedf31c7eb4b26a2d9df7c766427fdfd845e9f'
    
    git-subtree-dir: connector/rocketmq-connect-activemq
    git-subtree-mainline: a1e5f6084d893257cbe861e9ee8d25894200bb7d
    git-subtree-split: e8aedf31c7eb4b26a2d9df7c766427fdfd845e9f

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