This is an automated email from the ASF dual-hosted git repository. mikexue pushed a commit to branch revert-3438-fix_3404 in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
commit de0862e2f197483b86d12beeedcb2eeaed26837d Author: mike_xwm <[email protected]> AuthorDate: Mon Mar 13 14:38:02 2023 +0800 Revert "[ISSUE #3404] Use isEmpty() to check whether the collection is empty or not.[ ShowListenClientByTopicHandler]" --- .../eventmesh/runtime/admin/handler/ShowListenClientByTopicHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/ShowListenClientByTopicHandler.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/ShowListenClientByTopicHandler.java index bd33408a4..1cf6ef6ee 100644 --- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/ShowListenClientByTopicHandler.java +++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/ShowListenClientByTopicHandler.java @@ -68,7 +68,7 @@ public class ShowListenClientByTopicHandler extends AbstractHttpHandler { if (!clientGroupMap.isEmpty()) { for (ClientGroupWrapper cgw : clientGroupMap.values()) { Set<Session> listenSessionSet = cgw.getTopic2sessionInGroupMapping().get(topic); - if (listenSessionSet != null && listenSessionSet.isEmpty()) { + if (listenSessionSet != null && listenSessionSet.size() > 0) { result.append(String.format("group:%s", cgw.getGroup())).append(newLine); for (Session session : listenSessionSet) { UserAgent userAgent = session.getClient(); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
