Package org.apache.activemq.artemis.core.postoffice

Interface Bindings

All Superinterfaces:

UnproposalListener

All Known Implementing Classes:

BindingsImpl

public interface Bindings
extends UnproposalListener

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()
boolean	hasLocalBinding()
Message	redistribute(Message message, Queue originatingQueue, RoutingContext context)
Binding	removeBindingByUniqueName(SimpleString uniqueName)
void	route(Message message, RoutingContext context)
void	setMessageLoadBalancingType(MessageLoadBalancingType messageLoadBalancingType)
int	size()
void	updated(QueueBinding binding)

Methods inherited from interface org.apache.activemq.artemis.core.server.group.UnproposalListener

unproposed

Method Details

updated

void updated(QueueBinding binding)

getBindings

Collection<Binding> getBindings()

getBinding

Binding getBinding(String name)

addBinding

void addBinding(Binding binding)

removeBindingByUniqueName

Binding removeBindingByUniqueName(SimpleString uniqueName)

getName

SimpleString getName()

setMessageLoadBalancingType

void setMessageLoadBalancingType(MessageLoadBalancingType messageLoadBalancingType)

getMessageLoadBalancingType

MessageLoadBalancingType getMessageLoadBalancingType()

redistribute

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

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

void route(Message message,
 RoutingContext context)
    throws Exception

Throws:

Exception

allowRedistribute

boolean allowRedistribute()

forEach

void forEach(BiConsumer<String,Binding> bindingConsumer)

size

int size()

hasLocalBinding

boolean hasLocalBinding()