Skip to content

Commit 0afdfbf

Browse files
authored
Merge 8917ab6 into 8a014d4
2 parents 8a014d4 + 8917ab6 commit 0afdfbf

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/BatchSendMessageProcessor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -177,7 +177,7 @@ public void processRequest(ChannelHandlerContext ctx, AsyncContext<HttpCommand>
177177
eventSize = Integer.parseInt(Objects.requireNonNull(event.getExtension(SendMessageBatchRequestBody.SIZE)).toString());
178178
CloudEventData eventData = event.getData();
179179

180-
if (eventData != null || StringUtils.isBlank(batchId)
180+
if (eventData == null || StringUtils.isBlank(batchId)
181181
|| StringUtils.isBlank(producerGroup)
182182
|| eventSize != eventList.size()) {
183183
responseEventMeshCommand = asyncContext.getRequest().createHttpCommandResponse(

0 commit comments

Comments
 (0)