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,
MessageLoadBalancingType messageLoadBalancingType) |
Modifier and Type | Method and Description |
---|---|
void |
addConsumer(SimpleString filterString) |
void |
close() |
void |
connect() |
int |
consumerCount() |
void |
disconnect() |
SimpleString |
getAddress() |
Bindable |
getBindable() |
SimpleString |
getClusterName() |
int |
getDistance() |
Filter |
getFilter() |
Set<Filter> |
getFilters() |
long |
getID() |
Queue |
getQueue() |
long |
getRemoteQueueID() |
SimpleString |
getRoutingName() |
BindingType |
getType() |
SimpleString |
getUniqueName() |
boolean |
isConnected() |
boolean |
isExclusive() |
boolean |
isHighAcceptPriority(Message message) |
void |
removeConsumer(SimpleString filterString) |
void |
reset() |
void |
route(Message message,
RoutingContext context) |
void |
routeWithAck(Message message,
RoutingContext context) |
String |
toManagementString()
This method will create a string representation meant for management operations.
|
String |
toString() |
void |
unproposed(SimpleString groupID) |
public RemoteQueueBindingImpl(long id, SimpleString address, SimpleString uniqueName, SimpleString routingName, Long remoteQueueID, SimpleString filterString, Queue storeAndForwardQueue, SimpleString bridgeName, int distance, MessageLoadBalancingType messageLoadBalancingType) 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(Message message)
isHighAcceptPriority
in interface Binding
public void unproposed(SimpleString groupID)
unproposed
in interface UnproposalListener
public void route(Message message, RoutingContext context)
public void routeWithAck(Message message, RoutingContext context)
routeWithAck
in interface Binding
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 void reset()
reset
in interface RemoteQueueBinding
public int consumerCount()
consumerCount
in interface QueueBinding
public String toManagementString()
Binding
This is different from the toString() method that is meant for debugging and will contain information that regular users won't understand well.
toManagementString
in interface Binding
public void disconnect()
disconnect
in interface RemoteQueueBinding
public boolean isConnected()
isConnected
in interface Binding
public void connect()
connect
in interface RemoteQueueBinding
public void close() throws Exception
public long getRemoteQueueID()
getRemoteQueueID
in interface RemoteQueueBinding
Copyright © 2019 JBoss by Red Hat. All rights reserved.