public class RemoteQueueBindingImpl extends Object implements RemoteQueueBinding
Constructor and Description |
---|
RemoteQueueBindingImpl(long id,
SimpleString address,
SimpleString uniqueName,
SimpleString routingName,
Long remoteQueueID,
SimpleString filterString,
Queue storeAndForwardQueue,
SimpleString bridgeName,
int distance) |
Modifier and Type | Method and Description |
---|---|
void |
addConsumer(SimpleString filterString) |
void |
close() |
int |
consumerCount() |
SimpleString |
getAddress() |
Bindable |
getBindable() |
SimpleString |
getClusterName() |
int |
getDistance() |
Filter |
getFilter() |
Set<Filter> |
getFilters() |
long |
getID() |
Queue |
getQueue() |
SimpleString |
getRoutingName() |
BindingType |
getType() |
SimpleString |
getUniqueName() |
boolean |
isExclusive() |
boolean |
isHighAcceptPriority(ServerMessage message) |
void |
removeConsumer(SimpleString filterString) |
void |
route(ServerMessage message,
RoutingContext context) |
String |
toString() |
public RemoteQueueBindingImpl(long id, SimpleString address, SimpleString uniqueName, SimpleString routingName, Long remoteQueueID, SimpleString filterString, Queue storeAndForwardQueue, SimpleString bridgeName, int distance) throws Exception
Exception
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 BindingType getType()
public int getDistance()
getDistance
in interface Binding
public boolean isHighAcceptPriority(ServerMessage message)
isHighAcceptPriority
in interface Binding
public void route(ServerMessage message, RoutingContext context)
public void addConsumer(SimpleString filterString) throws Exception
addConsumer
in interface RemoteQueueBinding
Exception
public void removeConsumer(SimpleString filterString) throws Exception
removeConsumer
in interface RemoteQueueBinding
Exception
public int consumerCount()
consumerCount
in interface QueueBinding
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.