org.hornetq.core.postoffice.impl

Class LocalQueueBinding

java.lang.Object

org.hornetq.core.postoffice.impl.LocalQueueBinding

All Implemented Interfaces:

Binding, QueueBinding

public class LocalQueueBinding
extends Object
implements QueueBinding

A LocalQueueBinding

Author:

Tim Fox Created 28 Jan 2009 12:42:23

Constructor Summary

Constructors

Constructor and Description
LocalQueueBinding(SimpleString address, Queue queue, SimpleString nodeID)

Method Summary

Methods

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

LocalQueueBinding

public LocalQueueBinding(SimpleString address,
                 Queue queue,
                 SimpleString nodeID)

Method Detail

getID

public long getID()

Specified by:

getID in interface Binding

getFilter

public Filter getFilter()

Specified by:

getFilter in interface Binding

getAddress

public SimpleString getAddress()

Specified by:

getAddress in interface Binding

getBindable

public Bindable getBindable()

Specified by:

getBindable in interface Binding

getQueue

public Queue getQueue()

Specified by:

getQueue in interface QueueBinding

getRoutingName

public SimpleString getRoutingName()

Specified by:

getRoutingName in interface Binding

getUniqueName

public SimpleString getUniqueName()

Specified by:

getUniqueName in interface Binding

getClusterName

public SimpleString getClusterName()

Specified by:

getClusterName in interface Binding

isExclusive

public boolean isExclusive()

Specified by:

isExclusive in interface Binding

getDistance

public int getDistance()

Specified by:

getDistance in interface Binding

isHighAcceptPriority

public boolean isHighAcceptPriority(ServerMessage message)

Specified by:

isHighAcceptPriority in interface Binding

route

public void route(ServerMessage message,
         RoutingContext context)
           throws Exception

Specified by:

route in interface Binding

Throws:

Exception

isQueueBinding

public boolean isQueueBinding()

consumerCount

public int consumerCount()

Specified by:

consumerCount in interface QueueBinding

getType

public BindingType getType()

Specified by:

getType in interface Binding

close

public void close()
           throws Exception

Specified by:

close in interface Binding

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object