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 ofSimpleMessageGroupMap
when implementing the Message Groups functionality.
-
-
Constructor Summary
Constructors Constructor Description MessageGroupHashBucketFactory()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description MessageGroupMap
createMessageGroupMap()
int
getBucketCount()
int
getCacheSize()
void
setBucketCount(int bucketCount)
Sets the number of hash buckets to use for the message group functionality.void
setCacheSize(int cacheSize)
-
-
-
Method Detail
-
createMessageGroupMap
public MessageGroupMap createMessageGroupMap()
- Specified by:
createMessageGroupMap
in 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)
-
-