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 232c585 Add 'connector/rocketmq-connect-mongo/' from commit
'b307466f3fc4fa25ba21de87c568a4095cf18f4f'
new 4e42a37 Initial rocketmq-connect-rabbitmq
new a7ab1c4 [ISSUE #312] Implement rocketmq connect RabbitMQ (#313)
new 5feab9c Add 'connector/rocketmq-connect-rabbitmq/' from commit
'a7ab1c46a9938df2984c3ad730609c1a7797cc9b'
The 3 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:
.../README.md | 9 +-
connector/rocketmq-connect-rabbitmq/pom.xml | 205 +++++++++++++++++++++
.../rocketmq/connect/rabbitmq}/ErrorCode.java | 2 +-
.../rocketmq/connect/rabbitmq/RabbitmqConfig.java | 61 ++++++
.../connector/RabbitmqSourceConnector.java | 30 +--
.../rabbitmq/connector/RabbitmqSourceTask.java} | 33 ++--
.../rabbitmq/pattern/RabbitMQPatternProcessor.java | 48 +++++
.../rocketmq/connect/jms/RabbitmqConfigTest.java} | 13 +-
.../connector/RabbitmqSourceConnectorTest.java} | 52 +++---
.../rabbitmq/connector/RabbitmqSourceTaskTest.java | 164 +++++++++++++++++
.../pattern/RabbitMQPatternProcessorTest.java} | 34 ++--
11 files changed, 554 insertions(+), 97 deletions(-)
copy connector/{rocketmq-connect-activemq =>
rocketmq-connect-rabbitmq}/README.md (71%)
create mode 100644 connector/rocketmq-connect-rabbitmq/pom.xml
copy
connector/{rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq
=>
rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq}/ErrorCode.java
(74%)
create mode 100644
connector/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/RabbitmqConfig.java
copy
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
=>
connector/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceConnector.java
(65%)
copy
connector/{rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/EnumColumnParser.java
=>
rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceTask.java}
(55%)
create mode 100644
connector/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/pattern/RabbitMQPatternProcessor.java
copy
connector/{rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/DivideStrategyEnum.java
=>
rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/jms/RabbitmqConfigTest.java}
(82%)
copy
connector/{rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqConnectorTest.java
=>
rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceConnectorTest.java}
(51%)
create mode 100644
connector/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceTaskTest.java
copy
connector/{rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTaskTest.java
=>
rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/pattern/RabbitMQPatternProcessorTest.java}
(53%)
