Package org.apache.activemq.network

Class DemandSubscription

java.lang.Object

org.apache.activemq.network.DemandSubscription

public class DemandSubscription
extends Object

Represents a network bridge interface

Method Summary

Modifier and Type	Method	Description
boolean	add(ConsumerId id)	Increment the consumers associated with this subscription
boolean	addForcedDurableConsumer(ConsumerId id)
void	decrementOutstandingResponses()
Set<SubscriptionInfo>	getDurableRemoteSubs()
int	getForcedDurableConsumersSize()
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
boolean	removeForcedDurableConsumer(ConsumerId id)
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.

addForcedDurableConsumer

public boolean addForcedDurableConsumer(ConsumerId id)

removeForcedDurableConsumer

public boolean removeForcedDurableConsumer(ConsumerId id)

getForcedDurableConsumersSize

public int getForcedDurableConsumersSize()

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)