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