Class MessageGroupHashBucketFactory
- java.lang.Object
-
- org.apache.activemq.broker.region.group.MessageGroupHashBucketFactory
-
- All Implemented Interfaces:
MessageGroupMapFactory
public class MessageGroupHashBucketFactory extends Object implements MessageGroupMapFactory
A factory to create instances ofSimpleMessageGroupMapwhen implementing the Message Groups functionality.
-
-
Constructor Summary
Constructors Constructor Description MessageGroupHashBucketFactory()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description MessageGroupMapcreateMessageGroupMap()intgetBucketCount()intgetCacheSize()voidsetBucketCount(int bucketCount)Sets the number of hash buckets to use for the message group functionality.voidsetCacheSize(int cacheSize)
-
-
-
Method Detail
-
createMessageGroupMap
public MessageGroupMap createMessageGroupMap()
- Specified by:
createMessageGroupMapin interfaceMessageGroupMapFactory
-
getBucketCount
public int getBucketCount()
-
setBucketCount
public void setBucketCount(int bucketCount)
Sets the number of hash buckets to use for the message group functionality. This is only applicable to using message groups to parallelize processing of a queue while preserving order across an individual JMSXGroupID header value. This value sets the number of hash buckets that will be used (i.e. the maximum possible concurrency).
-
getCacheSize
public int getCacheSize()
-
setCacheSize
public void setCacheSize(int cacheSize)
-
-