You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2023/01/03 07:24:15 UTC
[rocketmq-connect] branch master updated: upgradeDingTalkOpentMessingConnector (#404)
This is an automated email from the ASF dual-hosted git repository.
zhoubo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
The following commit(s) were added to refs/heads/master by this push:
new 771bc020 upgradeDingTalkOpentMessingConnector (#404)
771bc020 is described below
commit 771bc0203b733666ea6ee966b70fe8ca975f25aa
Author: Artisan <Xi...@outlook.com>
AuthorDate: Tue Jan 3 15:24:11 2023 +0800
upgradeDingTalkOpentMessingConnector (#404)
* upgradeDingTalkOpentMessingConnector
* updateDingTalkSinkTest
* updateLocalPath
* addFolder
* updateTest
* updateDingTalkSinkUnitTest
* recoverConfDefault
* updateTest
Co-authored-by: Artisan <Am...@gmail.com>
---
.../rocketmq/connect/dingtalk/sink/DingTalkSinkConnectorTest.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/connectors/aliyun/rocketmq-connect-dingtalk/src/test/java/org/apache/rocketmq/connect/dingtalk/sink/DingTalkSinkConnectorTest.java b/connectors/aliyun/rocketmq-connect-dingtalk/src/test/java/org/apache/rocketmq/connect/dingtalk/sink/DingTalkSinkConnectorTest.java
index 7f04c3d0..55c7e102 100644
--- a/connectors/aliyun/rocketmq-connect-dingtalk/src/test/java/org/apache/rocketmq/connect/dingtalk/sink/DingTalkSinkConnectorTest.java
+++ b/connectors/aliyun/rocketmq-connect-dingtalk/src/test/java/org/apache/rocketmq/connect/dingtalk/sink/DingTalkSinkConnectorTest.java
@@ -1,5 +1,6 @@
package org.apache.rocketmq.connect.dingtalk.sink;
+import com.alibaba.fastjson.JSON;
import io.openmessaging.KeyValue;
import io.openmessaging.connector.api.data.ConnectRecord;
import io.openmessaging.internal.DefaultKeyValue;
@@ -26,8 +27,8 @@ public class DingTalkSinkConnectorTest {
DingTalkSinkTask dingTalkSinkTask = new DingTalkSinkTask();
KeyValue keyValue = new DefaultKeyValue();
// Replace it with your own robot webhook.
- keyValue.put("webHook", "https://oapi.dingtalk.com/robot/send?access_token=7f78aa4734ea9bd245984e47b6764ccb950b4292e4f6f9424dff92909f485f16");
- keyValue.put("secretKey", "SEC8a898c9df7b6415090a8f1341d9eed000c815a89f301f2de87302a1e802dbd69");
+ keyValue.put("webHook", "https://oapi.dingtalk.com/robot/send?access_token=xxxxxxxx");
+ keyValue.put("secretKey", "Replace it with your own robot secretKey.");
dingTalkSinkTask.start(keyValue);
Map<String, Object> map = new HashMap<>();
map.put("msgtype", "text");
@@ -36,7 +37,7 @@ public class DingTalkSinkConnectorTest {
map.put("text", map1);
List<ConnectRecord> connectRecordList = new ArrayList<>();
ConnectRecord connectRecord = new ConnectRecord(null, null, System.currentTimeMillis());
- connectRecord.setData(map);
+ connectRecord.setData(JSON.toJSONString(map));
connectRecordList.add(connectRecord);
dingTalkSinkTask.put(connectRecordList);
}