This is an automated email from the ASF dual-hosted git repository.
mxsm 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 37fcbb1e6 [ISSUE #4799]Change the logging level of `msg ignored` from
error to warn (#4803)
37fcbb1e6 is described below
commit 37fcbb1e666efa227a52235fab415db2db2ae171
Author: Pil0tXia <[email protected]>
AuthorDate: Tue Mar 26 00:01:41 2024 +0800
[ISSUE #4799]Change the logging level of `msg ignored` from error to warn
(#4803)
---
.../java/org/apache/eventmesh/runtime/client/impl/PubClientImpl.java | 4 ++--
.../java/org/apache/eventmesh/runtime/client/impl/SubClientImpl.java | 2 +-
.../eventmesh/client/tcp/impl/AbstractEventMeshTCPSubHandler.java | 4 ++--
3 files changed, 5 insertions(+), 5 deletions(-)
diff --git
a/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/impl/PubClientImpl.java
b/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/impl/PubClientImpl.java
index cb6cf5dab..873567454 100644
---
a/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/impl/PubClientImpl.java
+++
b/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/impl/PubClientImpl.java
@@ -195,7 +195,7 @@ public class PubClientImpl extends TCPClient implements
PubClient {
contexts.remove(context.getKey());
context.finish(msg);
} else {
- log.error("msg ignored,context not found .|{}|{}", cmd,
msg);
+ log.warn("msg ignored,context not found.|{}|{}", cmd, msg);
}
} else if (cmd == Command.SERVER_GOODBYE_REQUEST) {
log.error("server goodbye request:
---------------------------{}", msg);
@@ -206,7 +206,7 @@ public class PubClientImpl extends TCPClient implements
PubClient {
contexts.remove(context.getKey());
context.finish(msg);
} else {
- log.error("msg ignored,context not found .|{}|{}", cmd,
msg);
+ log.warn("msg ignored,context not found.|{}|{}", cmd, msg);
}
}
}
diff --git
a/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/impl/SubClientImpl.java
b/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/impl/SubClientImpl.java
index f419d0d21..841676f02 100644
---
a/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/impl/SubClientImpl.java
+++
b/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/impl/SubClientImpl.java
@@ -236,7 +236,7 @@ public class SubClientImpl extends TCPClient implements
SubClient {
contexts.remove(context.getKey());
context.finish(msg);
} else {
- log.error("msg ignored,context not found.|{}|{}", cmd,
msg);
+ log.warn("msg ignored,context not found.|{}|{}", cmd, msg);
}
}
}
diff --git
a/eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/AbstractEventMeshTCPSubHandler.java
b/eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/AbstractEventMeshTCPSubHandler.java
index 4669244b9..0c9a69547 100644
---
a/eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/AbstractEventMeshTCPSubHandler.java
+++
b/eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/AbstractEventMeshTCPSubHandler.java
@@ -63,14 +63,14 @@ public abstract class
AbstractEventMeshTCPSubHandler<ProtocolMessage> extends Si
// TODO
break;
default:
- log.error("msg ignored|{}|{}", cmd, msg);
+ log.warn("msg ignored|{}|{}", cmd, msg);
}
RequestContext context = contexts.get(RequestContext.key(msg));
if (context != null) {
contexts.remove(context.getKey());
context.finish(msg);
} else {
- log.error("msg ignored,context not found.|{}|{}", cmd, msg);
+ log.warn("msg ignored,context not found.|{}|{}", cmd, msg);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
