fix 发送事件
This commit is contained in:
@@ -130,8 +130,9 @@ public class SpokesManService {
|
|||||||
CloudEvents cloudEvents = new CloudEvents();
|
CloudEvents cloudEvents = new CloudEvents();
|
||||||
cloudEvents.setData(difSpokesManResult);
|
cloudEvents.setData(difSpokesManResult);
|
||||||
cloudEvents.setSource(sourceId);
|
cloudEvents.setSource(sourceId);
|
||||||
cloudEvents.setSpecversion("3.1.51");
|
cloudEvents.setSpecversion("1.0");
|
||||||
cloudEvents.setType("ai-analytic-center");
|
cloudEvents.setDatacontenttype("application/json");
|
||||||
|
cloudEvents.setType("SPOKESMAN");
|
||||||
cloudEvents.setId(aiAnalysisRequestId);
|
cloudEvents.setId(aiAnalysisRequestId);
|
||||||
huaWeiEGService.sendEvent(cloudEvents, channelId);
|
huaWeiEGService.sendEvent(cloudEvents, channelId);
|
||||||
//异步更新dify响应日志
|
//异步更新dify响应日志
|
||||||
|
|||||||
Reference in New Issue
Block a user