This is an automated email from the ASF dual-hosted git repository.
mikexue 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 6a8a7f706 [ISSUE #3823]Math operands should be cast before assignment.
6a8a7f706 is described below
commit 6a8a7f70653fea4a67a6def4efc543af0afc865a
Author: maheshnikam <[email protected]>
AuthorDate: Sat May 6 14:03:06 2023 +0530
[ISSUE #3823]Math operands should be cast before assignment.
---
.../org/apache/eventmesh/storage/standalone/admin/StandaloneAdmin.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/admin/StandaloneAdmin.java
b/eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/admin/StandaloneAdmin.java
index 8886c1abe..71a15b7cd 100644
---
a/eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/admin/StandaloneAdmin.java
+++
b/eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/admin/StandaloneAdmin.java
@@ -75,9 +75,10 @@ public class StandaloneAdmin implements Admin {
List<TopicProperties> topicList = new ArrayList<>();
messageContainer.keySet().forEach(topicMetadata -> {
MessageQueue messageQueue = messageContainer.get(topicMetadata);
+ final int messageCount = messageQueue.getPutIndex() -
messageQueue.getTakeIndex();
topicList.add(new TopicProperties(
topicMetadata.getTopicName(),
- messageQueue.getPutIndex() - messageQueue.getTakeIndex()
+ messageCount
));
});
topicList.sort(Comparator.comparing(t -> t.name));
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
