Merge pull request #1106 from pzygielo/useless-b

Author: pzygielo

mq/main/mq-broker/broker-core/src/main/java/com/sun/messaging/jmq/jmsserver/core/Consumer.java

@@ -703,7 +703,7 @@ public void setParentList(PartitionedStore pstore, SubSet set) {
     }
 
     protected void getMoreMessages(int num) {
-        Map<PartitionedStore, SubSet> ss = new LinkedHashMap<>();
+        final Map<PartitionedStore, SubSet> ss = new LinkedHashMap<>();
         synchronized (parentListMap) {
             ss.putAll(parentListMap);
         }
@@ -717,7 +717,8 @@ protected void getMoreMessages(int num) {
                 return;
             }
             SubSet pl = null;
-            while (!isFailover && isActive() && !isPaused() && isValid() && ss != null && (pl = getNonEmptyParentList(ss, pl)) != null && count < num
+            assert ss != null;
+            while (!isFailover && isActive() && !isPaused() && isValid() && (pl = getNonEmptyParentList(ss, pl)) != null && count < num
                     && (parent == null || !parent.isPaused())) {
 
                 PacketReference mm = (PacketReference) pl.removeNext();