Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

AMQ-9156 - fix formatting

This commit is contained in:
Christopher L. Shannon (cshannon) 2022-11-03 10:44:26 -04:00
parent 9c5a6219ea
commit 3bd099f469
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-broker/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java
View File

@ -358,7 +358,7 @@ public class TopicSubscription extends AbstractSubscription {
if (isUseTopicSubscriptionInflightStats()) {
synchronized(dispatchLock) {
for (DispatchedNode node : dispatched) {
if (node.getDestination()== destination) {
if (node.getDestination() == destination) {
//We only need to clean up inflight message size here on the sub stats as
//inflight on destination stat is cleaned up on destroy
getSubscriptionStatistics().getInflightMessageSize().addSize(-node.getSize());