You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2022/03/02 06:15:02 UTC
[rocketmq-connect] 04/10: Add 'connectors/rocketmq-connect-jms/' from commit '37a4db762dfac7496e2e0e40cf7cf25c4bd0f01d'

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 8ad07046d7eb4516d8f01dd994de33a18cac3826
Merge: cbb84d7 37a4db7
Author: odbozhou <87...@qq.com>
AuthorDate: Wed Mar 2 14:12:14 2022 +0800

    Add 'connectors/rocketmq-connect-jms/' from commit '37a4db762dfac7496e2e0e40cf7cf25c4bd0f01d'
    
    git-subtree-dir: connectors/rocketmq-connect-jms
    git-subtree-mainline: cbb84d72cfe01e18de40aaf107e5da49847f567b
    git-subtree-split: 37a4db762dfac7496e2e0e40cf7cf25c4bd0f01d

 connectors/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 connectors/rocketmq-connect-jms/pom.xml
index 0000000,50e0490..50e0490
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jms/pom.xml
+++ b/connectors/rocketmq-connect-jms/pom.xml
diff --cc connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Config.java
index 0000000,1e69f89..1e69f89
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Config.java
+++ b/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Config.java
diff --cc connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/ErrorCode.java
index 0000000,b6dafb1..b6dafb1
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/ErrorCode.java
+++ b/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/ErrorCode.java
diff --cc connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Replicator.java
index 0000000,3e859a4..3e859a4
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Replicator.java
+++ b/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Replicator.java
diff --cc connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnector.java
index 0000000,68f7677..68f7677
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnector.java
+++ b/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnector.java
diff --cc connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceTask.java
index 0000000,7b1f7c4..7b1f7c4
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceTask.java
+++ b/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceTask.java
diff --cc connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/pattern/PatternProcessor.java
index 0000000,5399045..5399045
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/pattern/PatternProcessor.java
+++ b/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/pattern/PatternProcessor.java
diff --cc connectors/rocketmq-connect-jms/src/test/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnectorTest.java
index 0000000,632c9d3..632c9d3
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jms/src/test/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnectorTest.java
+++ b/connectors/rocketmq-connect-jms/src/test/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnectorTest.java