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 d8ef9b20 Bump elasticsearch in
/connectors/rocketmq-connect-elasticsearch (#361)
add 1ba97c9f [ISSUE #344] rabbitmq source connector adapt to new api (#345)
No new revisions were added by this update.
Summary of changes:
.../org/apache/rocketmq/connect/jms/Config.java | 64 ++++++++-----
.../jms/connector/BaseJmsSourceConnector.java | 10 +-
.../connect/jms/connector/BaseJmsSourceTask.java | 20 ++--
.../connect/jms/pattern/PatternProcessor.java | 35 ++++---
connectors/rocketmq-connect-rabbitmq/README.md | 38 ++++++--
connectors/rocketmq-connect-rabbitmq/pom.xml | 35 ++++---
.../rocketmq/connect/rabbitmq/RabbitmqConfig.java | 32 +------
.../connector/RabbitmqSourceConnector.java | 3 +-
.../rabbitmq/connector/RabbitmqSourceTask.java | 5 +
.../rabbitmq/pattern/RabbitMQPatternProcessor.java | 24 ++---
.../connector/RabbitmqSourceConnectorTest.java | 16 ----
.../rabbitmq/connector/RabbitmqSourceTaskTest.java | 106 +++++----------------
.../pattern/RabbitMQPatternProcessorTest.java | 5 +-
13 files changed, 179 insertions(+), 214 deletions(-)
