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 6141d4b71 fixes#3392
new d94a2b90c Merge pull request #3814 from nikam14/patch-16
6141d4b71 is described below
commit 6141d4b7167929d61e3ed0216f7806d409183508
Author: maheshnikam <[email protected]>
AuthorDate: Tue Apr 25 13:09:36 2023 +0530
fixes#3392
---
.../protocol/http/processor/BatchSendMessageV2Processor.java | 9 +++++----
1 file changed, 5 insertions(+), 4 deletions(-)
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/BatchSendMessageV2Processor.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/BatchSendMessageV2Processor.java
index e85fbee57..64bd8f15f 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/BatchSendMessageV2Processor.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/BatchSendMessageV2Processor.java
@@ -58,9 +58,11 @@ import io.netty.channel.ChannelHandlerContext;
public class BatchSendMessageV2Processor 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 final EventMeshHTTPServer eventMeshHTTPServer;
@@ -71,7 +73,6 @@ public class BatchSendMessageV2Processor implements
HttpRequestProcessor {
this.acl = eventMeshHTTPServer.getAcl();
}
- public Logger batchMessageLogger = LoggerFactory.getLogger("batchMessage");
@Override
public void processRequest(ChannelHandlerContext ctx,
AsyncContext<HttpCommand> asyncContext)
@@ -161,7 +162,7 @@ public class BatchSendMessageV2Processor implements
HttpRequestProcessor {
return;
}
- String content = new String(event.getData().toBytes(),
StandardCharsets.UTF_8);
+ String content = new
String(Objects.requireNonNull(event.getData()).toBytes(),
StandardCharsets.UTF_8);
if (content.length() >
eventMeshHTTPServer.getEventMeshHttpConfiguration().getEventMeshEventSize()) {
batchMessageLogger.error("Event size exceeds the limit: {}",
eventMeshHTTPServer.getEventMeshHttpConfiguration().getEventMeshEventSize());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
