public final class BindingsImpl extends Object implements Bindings
Modifier and Type | Field and Description |
---|---|
static int |
MAX_GROUP_RETRY |
Constructor and Description |
---|
BindingsImpl(SimpleString name,
GroupingHandler groupingHandler,
PagingStore pageStore) |
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) |
public static final int MAX_GROUP_RETRY
public BindingsImpl(SimpleString name, GroupingHandler groupingHandler, PagingStore pageStore)
public void setRouteWhenNoConsumers(boolean routeWhenNoConsumers)
setRouteWhenNoConsumers
in interface Bindings
public Collection<Binding> getBindings()
getBindings
in interface Bindings
public void unproposed(SimpleString groupID)
unproposed
in interface UnproposalListener
public void addBinding(Binding binding)
addBinding
in interface Bindings
public void removeBinding(Binding binding)
removeBinding
in interface Bindings
public boolean redistribute(ServerMessage message, Queue originatingQueue, RoutingContext context) throws Exception
redistribute
in interface Bindings
Exception
public void route(ServerMessage message, RoutingContext context) throws Exception
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.