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()
           
 ConsumerInfo getLocalInfo()
           
 NetworkBridgeFilter getNetworkBridgeFilter()
           
 ConsumerInfo getRemoteInfo()
           
 boolean incrementOutstandingResponses()
           
 boolean isEmpty()
           
 boolean remove(ConsumerId id)
          Increment the consumers associated with this subscription
 void setNetworkBridgeFilter(NetworkBridgeFilter networkBridgeFilter)
           
 int size()
           
 void waitForCompletion()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

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

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)


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.