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

Class DisabledMessageGroups<C>

java.lang.Object

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

Type Parameters:

C - the value type.

All Implemented Interfaces:

MessageGroups<C>

public class DisabledMessageGroups<C>
extends Object

Implementation of MessageGroups that simply uses a NoOpMap, and in essence disables message grouping for queues that use it.

Method Summary

Modifier and Type	Method	Description
C	get(SimpleString key)
static <C> DisabledMessageGroups<C>	instance()
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

Method Details

instance

public static <C> DisabledMessageGroups<C> instance()

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>