diff --git a/eventmesh-protocol-plugin/eventmesh-protocol-webhook/src/main/java/org/apache/eventmesh/protocol/webhook/WebHookProtocolAdaptor.java b/eventmesh-protocol-plugin/eventmesh-protocol-webhook/src/main/java/org/apache/eventmesh/protocol/webhook/WebHookProtocolAdaptor.java index badca0a135..e541f69aad 100644 --- a/eventmesh-protocol-plugin/eventmesh-protocol-webhook/src/main/java/org/apache/eventmesh/protocol/webhook/WebHookProtocolAdaptor.java +++ b/eventmesh-protocol-plugin/eventmesh-protocol-webhook/src/main/java/org/apache/eventmesh/protocol/webhook/WebHookProtocolAdaptor.java @@ -21,6 +21,7 @@ import org.apache.eventmesh.common.protocol.ProtocolTransportObject; import org.apache.eventmesh.common.protocol.http.HttpEventWrapper; import org.apache.eventmesh.common.protocol.http.WebhookProtocolTransportObject; +import org.apache.eventmesh.common.utils.RandomStringUtils; import org.apache.eventmesh.protocol.api.ProtocolAdaptor; import org.apache.eventmesh.protocol.api.exception.ProtocolHandleException; @@ -47,6 +48,8 @@ public CloudEvent toCloudEvent(WebhookProtocolTransportObject protocol) throws P .withType(protocol.getEventType()) .withData(protocol.getBody()) .withExtension(Constants.PROTOCOL_TYPE, "webhook") + .withExtension("bizseqno", RandomStringUtils.generateNum(30)) + .withExtension("uniqueid", RandomStringUtils.generateNum(30)) .build(); } diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/ShowListenClientByTopicHandler.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/ShowListenClientByTopicHandler.java index 0f79f4737a..0ce5ed7bd1 100644 --- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/ShowListenClientByTopicHandler.java +++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/ShowListenClientByTopicHandler.java @@ -54,7 +54,7 @@ public ShowListenClientByTopicHandler(EventMeshTCPServer eventMeshTCPServer) { @Override public void handle(HttpExchange httpExchange) throws IOException { StringBuilder result = new StringBuilder(); - try(OutputStream out = httpExchange.getResponseBody();) { + try (OutputStream out = httpExchange.getResponseBody()) { String queryString = httpExchange.getRequestURI().getQuery(); Map queryStringInfo = NetUtils.formData2Dic(queryString); String topic = queryStringInfo.get(EventMeshConstants.MANAGE_TOPIC);