org.jboss.messaging.core.server.cluster.impl
Class RemoteQueueBindingImpl

java.lang.Object
  extended by org.jboss.messaging.core.server.cluster.impl.RemoteQueueBindingImpl
All Implemented Interfaces:
Binding, QueueBinding, RemoteQueueBinding

public class RemoteQueueBindingImpl
extends java.lang.Object
implements RemoteQueueBinding

A RemoteQueueBindingImpl

Author:
Tim Fox Created 21 Jan 2009 18:55:22

Constructor Summary
RemoteQueueBindingImpl(SimpleString address, SimpleString uniqueName, SimpleString routingName, int remoteQueueID, SimpleString filterString, Queue storeAndForwardQueue, SimpleString bridgeName, int distance)
           
 
Method Summary
 void addConsumer(SimpleString filterString)
           
 int consumerCount()
           
 SimpleString getAddress()
           
 Bindable getBindable()
           
 SimpleString getClusterName()
           
 int getDistance()
           
 Filter getFilter()
           
 int getID()
           
 Queue getQueue()
           
 SimpleString getRoutingName()
           
 BindingType getType()
           
 SimpleString getUniqueName()
           
 boolean isExclusive()
           
 boolean isHighAcceptPriority(ServerMessage message)
           
 void removeConsumer(SimpleString filterString)
           
 void setID(int id)
           
 void willRoute(ServerMessage message)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

RemoteQueueBindingImpl

public RemoteQueueBindingImpl(SimpleString address,
                              SimpleString uniqueName,
                              SimpleString routingName,
                              int remoteQueueID,
                              SimpleString filterString,
                              Queue storeAndForwardQueue,
                              SimpleString bridgeName,
                              int distance)
                       throws java.lang.Exception
Throws:
java.lang.Exception
Method Detail

getID

public int getID()
Specified by:
getID in interface Binding

setID

public void setID(int id)
Specified by:
setID 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

getType

public BindingType getType()
Specified by:
getType in interface Binding

getFilter

public Filter getFilter()
Specified by:
getFilter 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

willRoute

public void willRoute(ServerMessage message)
Specified by:
willRoute in interface Binding

addConsumer

public void addConsumer(SimpleString filterString)
                 throws java.lang.Exception
Specified by:
addConsumer in interface RemoteQueueBinding
Throws:
java.lang.Exception

removeConsumer

public void removeConsumer(SimpleString filterString)
                    throws java.lang.Exception
Specified by:
removeConsumer in interface RemoteQueueBinding
Throws:
java.lang.Exception

consumerCount

public int consumerCount()
Specified by:
consumerCount in interface QueueBinding


Copyright © 2006 JBoss Inc. All Rights Reserved.