[ISSUE apache#3273] fix incorrect validation

epiao55 · Feb 26, 2023 · f25041f · f25041f
1 parent 5c63ab1
commit f25041f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../org/apache/eventmesh/runtime/core/protocol/http/processor/BatchSendMessageProcessor.java b/.../org/apache/eventmesh/runtime/core/protocol/http/processor/BatchSendMessageProcessor.java
@@ -178,7 +178,7 @@ public void processRequest(ChannelHandlerContext ctx, AsyncContext<HttpCommand>
             eventSize = Integer.parseInt(Objects.requireNonNull(event.getExtension(SendMessageBatchRequestBody.SIZE)).toString());
             CloudEventData eventData = event.getData();
 
-            if (eventData != null || StringUtils.isBlank(batchId)
+            if (eventData == null || StringUtils.isBlank(batchId)
                     || StringUtils.isBlank(producerGroup)
                     || eventSize != eventList.size()) {
                 responseEventMeshCommand = asyncContext.getRequest().createHttpCommandResponse(