Skip to content

Commit 5bf80a1

Browse files
authored
[ISSUE apache#4799]Change the logging level of msg ignored from error to warn (apache#4803)
1 parent 9a2eab7 commit 5bf80a1

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/impl/PubClientImpl.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -195,7 +195,7 @@ protected void channelRead0(ChannelHandlerContext ctx, Package msg) throws Excep
195195
contexts.remove(context.getKey());
196196
context.finish(msg);
197197
} else {
198-
log.error("msg ignored,context not found .|{}|{}", cmd, msg);
198+
log.warn("msg ignored,context not found.|{}|{}", cmd, msg);
199199
}
200200
} else if (cmd == Command.SERVER_GOODBYE_REQUEST) {
201201
log.error("server goodbye request: ---------------------------{}", msg);
@@ -206,7 +206,7 @@ protected void channelRead0(ChannelHandlerContext ctx, Package msg) throws Excep
206206
contexts.remove(context.getKey());
207207
context.finish(msg);
208208
} else {
209-
log.error("msg ignored,context not found .|{}|{}", cmd, msg);
209+
log.warn("msg ignored,context not found.|{}|{}", cmd, msg);
210210
}
211211
}
212212
}

eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/impl/SubClientImpl.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -236,7 +236,7 @@ protected void channelRead0(ChannelHandlerContext ctx, Package msg) throws Excep
236236
contexts.remove(context.getKey());
237237
context.finish(msg);
238238
} else {
239-
log.error("msg ignored,context not found.|{}|{}", cmd, msg);
239+
log.warn("msg ignored,context not found.|{}|{}", cmd, msg);
240240
}
241241
}
242242
}

eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/AbstractEventMeshTCPSubHandler.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -63,14 +63,14 @@ protected void channelRead0(ChannelHandlerContext ctx, Package msg) throws Excep
6363
// TODO
6464
break;
6565
default:
66-
log.error("msg ignored|{}|{}", cmd, msg);
66+
log.warn("msg ignored|{}|{}", cmd, msg);
6767
}
6868
RequestContext context = contexts.get(RequestContext.key(msg));
6969
if (context != null) {
7070
contexts.remove(context.getKey());
7171
context.finish(msg);
7272
} else {
73-
log.error("msg ignored,context not found.|{}|{}", cmd, msg);
73+
log.warn("msg ignored,context not found.|{}|{}", cmd, msg);
7474
}
7575
}
7676

0 commit comments

Comments
 (0)