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

Version:
$Revision: 1.1 $

Method Summary
 boolean add(ConsumerId id)
          Increment the consumers associated with this subscription
 int getDispatched()
           
 ConsumerInfo getLocalInfo()
           
 ConsumerInfo getRemoteInfo()
           
 int incrementDispatched()
           
 boolean isEmpty()
           
 boolean remove(ConsumerId id)
          Increment the consumers associated with this subscription
 void setDispatched(int dispatched)
           
 void setLocalInfo(ConsumerInfo localInfo)
           
 void setRemoteInfo(ConsumerInfo remoteInfo)
           
 
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 added

isEmpty

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

getDispatched

public int getDispatched()
Returns:
Returns the dispatched.

setDispatched

public void setDispatched(int dispatched)
Parameters:
dispatched - The dispatched to set.

incrementDispatched

public int incrementDispatched()
Returns:
dispatched count after incremented

getLocalInfo

public ConsumerInfo getLocalInfo()
Returns:
Returns the localInfo.

setLocalInfo

public void setLocalInfo(ConsumerInfo localInfo)
Parameters:
localInfo - The localInfo to set.

getRemoteInfo

public ConsumerInfo getRemoteInfo()
Returns:
Returns the remoteInfo.

setRemoteInfo

public void setRemoteInfo(ConsumerInfo remoteInfo)
Parameters:
remoteInfo - The remoteInfo to set.


Copyright © 2011 Apache Software Foundation. All Rights Reserved.