org.apache.activemq.network
Class DemandSubscription

java.lang.Object
  extended by org.apache.activemq.network.DemandSubscription

public class DemandSubscription
extends Object

Represents a network bridge interface


Method Summary
 boolean add(ConsumerId id)
          Increment the consumers associated with this subscription
 void decrementOutstandingResponses()
           
 Set<SubscriptionInfo> getDurableRemoteSubs()
           
 SubscriptionInfo getLocalDurableSubscriber()
           
 ConsumerInfo getLocalInfo()
           
 NetworkBridgeFilter getNetworkBridgeFilter()
           
 ConsumerInfo getRemoteInfo()
           
 boolean incrementOutstandingResponses()
           
 boolean isEmpty()
           
 boolean isStaticallyIncluded()
           
 boolean remove(ConsumerId id)
          Increment the consumers associated with this subscription
 void setLocalDurableSubscriber(SubscriptionInfo localDurableSubscriber)
           
 void setNetworkBridgeFilter(NetworkBridgeFilter networkBridgeFilter)
           
 void setStaticallyIncluded(boolean staticallyIncluded)
           
 int size()
           
 String toString()
           
 void waitForCompletion()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Method Detail

toString

public String toString()
Overrides:
toString in class Object

add

public boolean add(ConsumerId id)
Increment the consumers associated with this subscription

Parameters:
id -
Returns:
true if added

remove

public boolean remove(ConsumerId id)
Increment the consumers associated with this subscription

Parameters:
id -
Returns:
true if removed

getDurableRemoteSubs

public Set<SubscriptionInfo> getDurableRemoteSubs()

isEmpty

public boolean isEmpty()
Returns:
true if there are no interested consumers

size

public int size()

getLocalInfo

public ConsumerInfo getLocalInfo()
Returns:
Returns the localInfo.

getRemoteInfo

public ConsumerInfo getRemoteInfo()
Returns:
Returns the remoteInfo.

waitForCompletion

public void waitForCompletion()

decrementOutstandingResponses

public void decrementOutstandingResponses()

incrementOutstandingResponses

public boolean incrementOutstandingResponses()

getNetworkBridgeFilter

public NetworkBridgeFilter getNetworkBridgeFilter()

setNetworkBridgeFilter

public void setNetworkBridgeFilter(NetworkBridgeFilter networkBridgeFilter)

getLocalDurableSubscriber

public SubscriptionInfo getLocalDurableSubscriber()

setLocalDurableSubscriber

public void setLocalDurableSubscriber(SubscriptionInfo localDurableSubscriber)

isStaticallyIncluded

public boolean isStaticallyIncluded()

setStaticallyIncluded

public void setStaticallyIncluded(boolean staticallyIncluded)


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.