org.hornetq.core.postoffice.impl

Class BindingsImpl

java.lang.Object

org.hornetq.core.postoffice.impl.BindingsImpl

All Implemented Interfaces:

Bindings, UnproposalListener

public final class BindingsImpl
extends Object
implements Bindings

A BindingsImpl

Author:

Tim Fox

Created 11 Dec 2008 08:34:33

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()
boolean	redistribute(ServerMessage message, Queue originatingQueue, RoutingContext context)
void	removeBinding(Binding binding)
void	route(ServerMessage message, RoutingContext context)
void	setRouteWhenNoConsumers(boolean routeWhenNoConsumers)
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

setRouteWhenNoConsumers

public void setRouteWhenNoConsumers(boolean routeWhenNoConsumers)

Specified by:

setRouteWhenNoConsumers 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