bharanic-dev commented on a change in pull request #10201:
URL: https://github.com/apache/pulsar/pull/10201#discussion_r612024955
##########
File path:
pulsar-broker/src/main/java/org/apache/pulsar/broker/resourcegroup/ResourceUsageTransportManager.java
##########
@@ -159,9 +171,11 @@ public void received(Reader<byte[]> reader,
Message<byte[]> msg) {
private final Map<String, ResourceUsageConsumer>
consumerMap = new ConcurrentHashMap<String,
ResourceUsageConsumer>();
+ private long staleMessageCount = 0;
Review comment:
I added the variable with the intention of adding a unit test for it.
But could not figure out a easy way to do so. I am open to ideas if you have
suggestions on how I can add one. Else, I will remove this variable.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
