You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by yu...@apache.org on 2022/04/15 05:56:36 UTC
[rocketmq-connect] branch master updated (5727e5e -> e210a41)
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