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:05 UTC

[rocketmq-connect] branch master updated (07aa6e6 -> 5727e5e)

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 07aa6e6  [ISSUE #11] Add mns source task (#1)
     add 5727e5e  [ISSUE #10] Add ding talk sink (#2)

No new revisions were added by this update.

Summary of changes:
 .../aliyun/rocketmq-connect-dingtalk/README.md     |  43 ++++
 .../pom.xml                                        |  40 +--
 .../dingtalk/sink/DingTalkSinkConnector.java       |  71 ++++++
 .../connect/dingtalk/sink/DingTalkSinkTask.java    |  96 +++++++
 .../connect/dingtalk/sink/common/OkHttpUtils.java  | 280 +++++++++++++++++++++
 .../dingtalk/sink/constant/DingTalkConstant.java   |  12 +
 .../dingtalk/sink/DingTalkSinkConnectorTest.java   |  51 ++++
 7 files changed, 576 insertions(+), 17 deletions(-)
 create mode 100644 connectors/aliyun/rocketmq-connect-dingtalk/README.md
 copy connectors/aliyun/{rocketmq-connect-mns => rocketmq-connect-dingtalk}/pom.xml (89%)
 create mode 100644 connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/DingTalkSinkConnector.java
 create mode 100644 connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/DingTalkSinkTask.java
 create mode 100644 connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/common/OkHttpUtils.java
 create mode 100644 connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/constant/DingTalkConstant.java
 create mode 100644 connectors/aliyun/rocketmq-connect-dingtalk/src/test/java/org/apache/rocketmq/connect/dingtalk/sink/DingTalkSinkConnectorTest.java