org.apache.activemq.artemis.core.postoffice.impl

Class BindingsImpl

java.lang.Object

org.apache.activemq.artemis.core.postoffice.impl.BindingsImpl

All Implemented Interfaces:

Bindings, UnproposalListener

public final class BindingsImpl
extends Object
implements Bindings

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_GROUP_RETRY

Constructor Summary

Constructors

Constructor and Description
BindingsImpl(SimpleString name, GroupingHandler groupingHandler, PagingStore pageStore)

Method Summary

Modifier and Type	Method and Description
void	addBinding(Binding binding)
Collection<Binding>	getBindings()
Map<SimpleString,List<Binding>>	getRoutingNameBindingMap()
boolean	redistribute(ServerMessage message, Queue originatingQueue, RoutingContext context)
void	removeBinding(Binding binding)
void	route(ServerMessage message, RoutingContext context)
void	setMessageLoadBalancingType(MessageLoadBalancingType messageLoadBalancingType)
String	toString()
void	unproposed(SimpleString groupID)

Methods inherited from class java.lang.Object

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

Field Detail

MAX_GROUP_RETRY

public static final int MAX_GROUP_RETRY

See Also:

Constant Field Values

Constructor Detail

BindingsImpl

public BindingsImpl(SimpleString name,
                    GroupingHandler groupingHandler,
                    PagingStore pageStore)

Method Detail

setMessageLoadBalancingType

public void setMessageLoadBalancingType(MessageLoadBalancingType messageLoadBalancingType)

Specified by:

setMessageLoadBalancingType in interface Bindings

getBindings

public Collection<Binding> getBindings()

Specified by:

getBindings in interface Bindings

unproposed

public void unproposed(SimpleString groupID)

Specified by:

unproposed in interface UnproposalListener

addBinding

public void addBinding(Binding binding)

Specified by:

addBinding in interface Bindings

removeBinding

public void removeBinding(Binding binding)

Specified by:

removeBinding in interface Bindings

redistribute

public boolean redistribute(ServerMessage message,
                            Queue originatingQueue,
                            RoutingContext context)
                     throws Exception

Specified by:

redistribute in interface Bindings

Throws:

Exception

route

public void route(ServerMessage message,
                  RoutingContext context)
           throws Exception

Specified by:

route in interface Bindings

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object

getRoutingNameBindingMap

public Map<SimpleString,List<Binding>> getRoutingNameBindingMap()