Class LocalQueueBinding
java.lang.Object
org.apache.activemq.artemis.core.postoffice.impl.LocalQueueBinding
- All Implemented Interfaces:
Binding,QueueBinding,UnproposalListener
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()intintgetID()getQueue()getType()booleanbooleanbooleanisHighAcceptPriority(Message message) booleanisLocal()booleanvoidroute(Message message, RoutingContext context) voidrouteWithAck(Message message, RoutingContext context) This method will create a string representation meant for management operations.toString()voidunproposed(SimpleString groupID)
-
Constructor Details
-
LocalQueueBinding
-
-
Method Details
-
isLocal
public boolean isLocal() -
getID
-
getFilter
-
getAddress
- Specified by:
getAddressin interfaceBinding
-
getBindable
- Specified by:
getBindablein interfaceBinding
-
getQueue
- Specified by:
getQueuein interfaceQueueBinding
-
getRoutingName
- Specified by:
getRoutingNamein interfaceBinding
-
getUniqueName
- Specified by:
getUniqueNamein interfaceBinding
-
getClusterName
- Specified by:
getClusterNamein interfaceBinding
-
isExclusive
public boolean isExclusive()- Specified by:
isExclusivein interfaceBinding
-
getDistance
public int getDistance()- Specified by:
getDistancein interfaceBinding
-
isHighAcceptPriority
- Specified by:
isHighAcceptPriorityin interfaceBinding
-
unproposed
- Specified by:
unproposedin interfaceUnproposalListener
-
route
-
routeWithAck
- Specified by:
routeWithAckin interfaceBinding- Throws:
Exception
-
isQueueBinding
public boolean isQueueBinding() -
consumerCount
public int consumerCount()- Specified by:
consumerCountin interfaceQueueBinding
-
getType
-
close
-
toString
-
toManagementString
Description copied from interface:BindingThis method will create a string representation meant for management operations.This is different from the toString() method that is meant for debugging and will contain information that regular users won't understand well.
- Specified by:
toManagementStringin interfaceBinding
-
isConnected
public boolean isConnected()- Specified by:
isConnectedin interfaceBinding
-