diff --git a/src/main/java/net/engio/mbassy/multi/subscription/SubscriptionManager.java b/src/main/java/net/engio/mbassy/multi/subscription/SubscriptionManager.java index f787bb1..123d4cd 100644 --- a/src/main/java/net/engio/mbassy/multi/subscription/SubscriptionManager.java +++ b/src/main/java/net/engio/mbassy/multi/subscription/SubscriptionManager.java @@ -59,7 +59,7 @@ public class SubscriptionManager { public SubscriptionManager(int numberOfThreads) { - this.MAP_STRIPING = numberOfThreads/2; + this.MAP_STRIPING = numberOfThreads; this.LOAD_FACTOR = 0.8f; this.subscriptionsPerMessageSingle = new ConcurrentHashMap, Collection>(4, this.LOAD_FACTOR, this.MAP_STRIPING);