Package 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	Description
static final int	MAX_GROUP_RETRY

Constructor Summary

Constructors

Constructor	Description
BindingsImpl(SimpleString name, GroupingHandler groupingHandler, StorageManager storageManager)

Method Summary

Modifier and Type	Method	Description
void	addBinding(Binding binding)
boolean	allowRedistribute()
void	forEach(BiConsumer<String,Binding> bindingConsumer)
Binding	getBinding(String name)
Collection<Binding>	getBindings()
MessageLoadBalancingType	getMessageLoadBalancingType()
SimpleString	getName()
Map<SimpleString,List<Binding>>	getRoutingNameBindingMap()	debug method: used just for tests!!
boolean	hasLocalBinding()
Message	redistribute(Message message, Queue originatingQueue, RoutingContext context)
Binding	removeBindingByUniqueName(SimpleString bindingUniqueName)
void	route(Message message, RoutingContext context)
void	setMessageLoadBalancingType(MessageLoadBalancingType messageLoadBalancingType)
int	size()
String	toString()
void	unproposed(SimpleString groupID)
void	updated(QueueBinding binding)

Methods inherited from class java.lang.Object

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

Field Details

MAX_GROUP_RETRY

public static final int MAX_GROUP_RETRY

See Also:

• Constant Field Values

Constructor Details

BindingsImpl

public BindingsImpl(SimpleString name,
 GroupingHandler groupingHandler,
 StorageManager storageManager)

Method Details

getName

public SimpleString getName()

Specified by:

getName in interface Bindings

setMessageLoadBalancingType

public void setMessageLoadBalancingType(MessageLoadBalancingType messageLoadBalancingType)

Specified by:

setMessageLoadBalancingType in interface Bindings

getMessageLoadBalancingType

public MessageLoadBalancingType getMessageLoadBalancingType()

Specified by:

getMessageLoadBalancingType 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

getBinding

public Binding getBinding(String name)

Specified by:

getBinding in interface Bindings

addBinding

public void addBinding(Binding binding)

Specified by:

addBinding in interface Bindings

updated

public void updated(QueueBinding binding)

Specified by:

updated in interface Bindings

removeBindingByUniqueName

public Binding removeBindingByUniqueName(SimpleString bindingUniqueName)

Specified by:

removeBindingByUniqueName in interface Bindings

allowRedistribute

public boolean allowRedistribute()

Specified by:

allowRedistribute in interface Bindings

forEach

public void forEach(BiConsumer<String,Binding> bindingConsumer)

Specified by:

forEach in interface Bindings

size

public int size()

Specified by:

size in interface Bindings

hasLocalBinding

public boolean hasLocalBinding()

Specified by:

hasLocalBinding in interface Bindings

redistribute

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

Specified by:

redistribute in interface Bindings

Parameters:

message - the message being copied

Returns:

a Copy of the message if redistribution succeeded, or null if it wasn't redistributed

Throws:

Exception

route

public void route(Message 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()

debug method: used just for tests!!