This is an automated email from the ASF dual-hosted git repository.
qingshanpeng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new fe6d83df8 fixes#3391
new 91aab4d4e Merge pull request #3816 from nikam14/patch-17
fe6d83df8 is described below
commit fe6d83df86b8e42baf972e49afc75283ba59991d
Author: maheshnikam <[email protected]>
AuthorDate: Tue Apr 25 13:24:04 2023 +0530
fixes#3391
---
.../protocol/http/processor/BatchSendMessageProcessor.java | 12 +++++++-----
1 file changed, 7 insertions(+), 5 deletions(-)
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/BatchSendMessageProcessor.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/BatchSendMessageProcessor.java
index b3db33fdf..277d64142 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/BatchSendMessageProcessor.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/BatchSendMessageProcessor.java
@@ -64,11 +64,13 @@ import io.netty.channel.ChannelHandlerContext;
public class BatchSendMessageProcessor implements HttpRequestProcessor {
- public final Logger cmdLogger =
LoggerFactory.getLogger(EventMeshConstants.CMD);
+ private final Logger cmdLogger =
LoggerFactory.getLogger(EventMeshConstants.CMD);
- public final Logger aclLogger =
LoggerFactory.getLogger(EventMeshConstants.ACL);
+ private final Logger aclLogger =
LoggerFactory.getLogger(EventMeshConstants.ACL);
+
+ private final Logger batchMessageLogger =
LoggerFactory.getLogger("batchMessage");
- private EventMeshHTTPServer eventMeshHTTPServer;
+ private final EventMeshHTTPServer eventMeshHTTPServer;
private final Acl acl;
@@ -77,7 +79,7 @@ public class BatchSendMessageProcessor implements
HttpRequestProcessor {
this.acl = eventMeshHTTPServer.getAcl();
}
- public Logger batchMessageLogger = LoggerFactory.getLogger("batchMessage");
+
@Override
public void processRequest(ChannelHandlerContext ctx,
AsyncContext<HttpCommand> asyncContext) throws Exception {
@@ -236,7 +238,7 @@ public class BatchSendMessageProcessor implements
HttpRequestProcessor {
try {
this.acl.doAclCheckInHttpSend(remoteAddr, user, pass,
subsystem, cloudEvent.getSubject(), requestCode);
} catch (Exception e) {
- //String errorMsg = String.format("CLIENT HAS NO
PERMISSION,send failed, topic:%s, subsys:%s, realIp:%s", topic, subsys, realIp);
+
responseEventMeshCommand =
asyncContext.getRequest().createHttpCommandResponse(
sendMessageBatchResponseHeader,
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
