This is an automated email from the ASF dual-hosted git repository.
yukon pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
from 5727e5e [ISSUE #10] Add ding talk sink (#2)
add e210a41 [ISSUE #9] Add http sink task (#3)
No new revisions were added by this update.
Summary of changes:
connectors/rocketmq-connect-http/README.md | 41 ++++++++++++++
.../pom.xml | 18 +++---
.../connect/http/sink/HttpSinkConnector.java} | 30 +++++-----
.../rocketmq/connect/http/sink/HttpSinkTask.java | 65 ++++++++++++++++++++++
.../connect/http}/sink/common/OkHttpUtils.java | 8 +--
.../connect/http/sink/constant/HttpConstant.java | 8 +++
.../connect/http/sink/HttpSinkConnectorTest.java | 42 ++++++++++++++
7 files changed, 180 insertions(+), 32 deletions(-)
create mode 100644 connectors/rocketmq-connect-http/README.md
copy connectors/{aliyun/rocketmq-connect-dingtalk =>
rocketmq-connect-http}/pom.xml (94%)
copy
connectors/{aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/DingTalkSinkConnector.java
=>
rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/HttpSinkConnector.java}
(55%)
create mode 100644
connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/HttpSinkTask.java
copy
connectors/{aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk
=>
rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http}/sink/common/OkHttpUtils.java
(96%)
create mode 100644
connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/constant/HttpConstant.java
create mode 100644
connectors/rocketmq-connect-http/src/test/java/org/apache/rocketmq/connect/http/sink/HttpSinkConnectorTest.java
