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 b3cbb0b49f361aeb83fc1ec2d26f00c1d6b6e449 Merge: 24c083e 37a4db7 Author: odbozhou <[email protected]> AuthorDate: Wed Mar 2 11:20:19 2022 +0800 Add 'connector/rocketmq-connect-jms/' from commit '37a4db762dfac7496e2e0e40cf7cf25c4bd0f01d' git-subtree-dir: connector/rocketmq-connect-jms git-subtree-mainline: 24c083eccf9232b7ca7f18e0d0f236af2e68ba7f git-subtree-split: 37a4db762dfac7496e2e0e40cf7cf25c4bd0f01d connector/rocketmq-connect-jms/pom.xml | 196 +++++++++++++++++++++ .../org/apache/rocketmq/connect/jms/Config.java | 163 +++++++++++++++++ .../org/apache/rocketmq/connect/jms/ErrorCode.java | 8 + .../apache/rocketmq/connect/jms/Replicator.java | 67 +++++++ .../jms/connector/BaseJmsSourceConnector.java | 71 ++++++++ .../connect/jms/connector/BaseJmsSourceTask.java | 150 ++++++++++++++++ .../connect/jms/pattern/PatternProcessor.java | 90 ++++++++++ .../jms/connector/BaseJmsSourceConnectorTest.java | 82 +++++++++ 8 files changed, 827 insertions(+) diff --cc connector/rocketmq-connect-jms/pom.xml index 0000000,50e0490..50e0490 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jms/pom.xml +++ b/connector/rocketmq-connect-jms/pom.xml diff --cc connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Config.java index 0000000,1e69f89..1e69f89 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Config.java +++ b/connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Config.java diff --cc connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/ErrorCode.java index 0000000,b6dafb1..b6dafb1 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/ErrorCode.java +++ b/connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/ErrorCode.java diff --cc connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Replicator.java index 0000000,3e859a4..3e859a4 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Replicator.java +++ b/connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Replicator.java diff --cc connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnector.java index 0000000,68f7677..68f7677 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnector.java +++ b/connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnector.java diff --cc connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceTask.java index 0000000,7b1f7c4..7b1f7c4 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceTask.java +++ b/connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceTask.java diff --cc connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/pattern/PatternProcessor.java index 0000000,5399045..5399045 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/pattern/PatternProcessor.java +++ b/connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/pattern/PatternProcessor.java diff --cc connector/rocketmq-connect-jms/src/test/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnectorTest.java index 0000000,632c9d3..632c9d3 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jms/src/test/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnectorTest.java +++ b/connector/rocketmq-connect-jms/src/test/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnectorTest.java
