org.apache.activemq.network
Class DemandSubscription

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

public class DemandSubscription
extends java.lang.Object

Represents a network bridge interface


Method Summary
 boolean add(ConsumerId id)
          Increment the consumers associated with this subscription
 void decrementOutstandingResponses()
           
 ConsumerInfo getLocalInfo()
           
 ConsumerInfo getRemoteInfo()
           
 boolean incrementOutstandingResponses()
           
 boolean isEmpty()
           
 boolean remove(ConsumerId id)
          Increment the consumers associated with this subscription
 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

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


Copyright © 2005-2012. All Rights Reserved.