public class LocalQueueBinding extends Object implements QueueBinding
Constructor and Description |
---|
LocalQueueBinding(SimpleString address,
Queue queue,
SimpleString nodeID) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
int |
consumerCount() |
SimpleString |
getAddress() |
Bindable |
getBindable() |
SimpleString |
getClusterName() |
int |
getDistance() |
Filter |
getFilter() |
long |
getID() |
Queue |
getQueue() |
SimpleString |
getRoutingName() |
BindingType |
getType() |
SimpleString |
getUniqueName() |
boolean |
isExclusive() |
boolean |
isHighAcceptPriority(ServerMessage message) |
boolean |
isQueueBinding() |
void |
route(ServerMessage message,
RoutingContext context) |
String |
toString() |
public LocalQueueBinding(SimpleString address, Queue queue, SimpleString nodeID)
public SimpleString getAddress()
getAddress
in interface Binding
public Bindable getBindable()
getBindable
in interface Binding
public Queue getQueue()
getQueue
in interface QueueBinding
public SimpleString getRoutingName()
getRoutingName
in interface Binding
public SimpleString getUniqueName()
getUniqueName
in interface Binding
public SimpleString getClusterName()
getClusterName
in interface Binding
public boolean isExclusive()
isExclusive
in interface Binding
public int getDistance()
getDistance
in interface Binding
public boolean isHighAcceptPriority(ServerMessage message)
isHighAcceptPriority
in interface Binding
public void route(ServerMessage message, RoutingContext context) throws Exception
public boolean isQueueBinding()
public int consumerCount()
consumerCount
in interface QueueBinding
public BindingType getType()
public void close() throws Exception
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.