This closes #1892

artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/ConcurrentLongHashMap.java

@@ -199,7 +199,7 @@ public class ConcurrentLongHashMap<V> {
       private long[] keys;
       private V[] values;
 
-      private int capacity;
+      private volatile int capacity;
       private volatile int size;
       private int usedBuckets;
       private int resizeThreshold;
@@ -457,10 +457,10 @@ public class ConcurrentLongHashMap<V> {
             }
          }
 
-         capacity = newCapacity;
          keys = newKeys;
          values = newValues;
          usedBuckets = size;
+         capacity = newCapacity;
          resizeThreshold = (int) (capacity * MapFillFactor);
       }
 

artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/ConcurrentLongHashSet.java

@@ -165,7 +165,7 @@ public class ConcurrentLongHashSet {
       // Keys and values are stored interleaved in the table array
       private long[] table;
 
-      private int capacity;
+      private volatile int capacity;
       private volatile int size;
       private int usedBuckets;
       private int resizeThreshold;
@@ -374,9 +374,9 @@ public class ConcurrentLongHashSet {
             }
          }
 
-         capacity = newCapacity;
          table = newTable;
          usedBuckets = size;
+         capacity = newCapacity;
          resizeThreshold = (int) (capacity * SetFillFactor);
       }