Package org.apache.activemq.artemis.core.server.impl

Class BucketMessageGroups<C>

java.lang.Object

org.apache.activemq.artemis.core.server.impl.BucketMessageGroups<C>

All Implemented Interfaces:

MessageGroups<C>

public class BucketMessageGroups<C>
extends Object
implements MessageGroups<C>

BucketMessageGroups, stores values against a bucket, where the bucket used is based on the provided key objects hash.

As such where keys compute to the same bucket they will act on that stored value, not the unique specific key.

The number of buckets is provided at construction.

Constructor Summary

Constructors

Constructor	Description
BucketMessageGroups(int bucketCount)

Method Summary

Modifier and Type	Method	Description
C	get(SimpleString key)
void	put(SimpleString key, C consumer)
C	remove(SimpleString key)
void	removeAll()
boolean	removeIf(Predicate<? super C> filter)
int	size()
Map<SimpleString,C>	toMap()

Methods inherited from class java.lang.Object

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

Constructor Details

BucketMessageGroups

public BucketMessageGroups(int bucketCount)

Method Details

put

public void put(SimpleString key,
 C consumer)

Specified by:

put in interface MessageGroups<C>

get

public C get(SimpleString key)

Specified by:

get in interface MessageGroups<C>

remove

public C remove(SimpleString key)

Specified by:

remove in interface MessageGroups<C>

removeIf

public boolean removeIf(Predicate<? super C> filter)

Specified by:

removeIf in interface MessageGroups<C>

removeAll

public void removeAll()

Specified by:

removeAll in interface MessageGroups<C>

size

public int size()

Specified by:

size in interface MessageGroups<C>

toMap

public Map<SimpleString,C> toMap()

Specified by:

toMap in interface MessageGroups<C>