org.apache.activemq.broker.region.group
Class MessageGroupHashBucketFactory

java.lang.Object
  org.apache.activemq.broker.region.group.MessageGroupHashBucketFactory

All Implemented Interfaces:

MessageGroupMapFactory

public class MessageGroupHashBucketFactory
extends java.lang.Object
implements MessageGroupMapFactory

A factory to create instances of SimpleMessageGroupMap when implementing the Message Groups functionality.

Constructor Summary

MessageGroupHashBucketFactory()

Method Summary

MessageGroupMap	createMessageGroupMap()
int	getBucketCount()
void	setBucketCount(int bucketCount) Sets the number of hash buckets to use for the message group functionality.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MessageGroupHashBucketFactory

public MessageGroupHashBucketFactory()

Method Detail

createMessageGroupMap

public MessageGroupMap createMessageGroupMap()

Specified by:

createMessageGroupMap in interface MessageGroupMapFactory

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).