This is an automated email from the ASF dual-hosted git repository.
zhoubo pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git.
from a1e5f60 Merge branch 'rocketmq_connect1' of
https://github.com/apache/rocketmq-externals
new f4221ce (1)Rename rocketmq-connector to replicator (2) Initialize
RocketMQ activemq connect and runtime
new c7c0c04 init complete
new 30b02f4 change package name
new da0b21f change
new 6663768 change
new d50ffb8 message type
new 508eea1 add unit test
new 23a5b24 add licenses
new db391c5 change exception
new 3da8a3f format pom.xml
new e8aedf3 Change README.md (#301)
new 32a23ce Add 'connector/rocketmq-connect-activemq/' from commit
'e8aedf31c7eb4b26a2d9df7c766427fdfd845e9f'
The 12 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
connector/rocketmq-connect-activemq/README-CN.md | 16 ++
connector/rocketmq-connect-activemq/README.md | 16 ++
.../rocketmq-connect-activemq}/pom.xml | 134 +++++++----------
.../apache/rocketmq/connect/activemq/Config.java | 109 +++++++++++++-
.../rocketmq/connect/activemq/ErrorCode.java | 8 +
.../rocketmq/connect/activemq/Replicator.java | 63 ++++++++
.../connector/ActivemqSourceConnector.java | 28 ++--
.../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, 803 insertions(+), 98 deletions(-)
create mode 100644 connector/rocketmq-connect-activemq/README-CN.md
create mode 100644 connector/rocketmq-connect-activemq/README.md
copy {rocketmq-connect-runtime => connector/rocketmq-connect-activemq}/pom.xml
(62%)
copy
rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileUtils.java
=>
connector/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Config.java
(52%)
create mode 100644
connector/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/ErrorCode.java
create mode 100644
connector/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Replicator.java
copy
rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSourceConnector.java
=>
connector/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceConnector.java
(72%)
create mode 100644
connector/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTask.java
create mode 100644
connector/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/pattern/PatternProcessor.java
create mode 100644
connector/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/ReplicatorTest.java
create mode 100644
connector/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqConnectorTest.java
create mode 100644
connector/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTaskTest.java
