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

Class SimpleMessageGroups<C>

java.lang.Object

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

Type Parameters:

C - the value type.

All Implemented Interfaces:

MessageGroups<C>

public class SimpleMessageGroups<C>
extends Object

Implementation of MessageGroups that simply uses a HashMap, this is the existing and default behaviour of message groups in artemis.

Effectively every Group Id is mapped raw, it also is unbounded.

Constructor Summary

Constructors

Constructor	Description
SimpleMessageGroups()

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

SimpleMessageGroups

public SimpleMessageGroups()

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>