public class DemandSubscription extends Object
Modifier and Type | Method and Description |
---|---|
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() |
public boolean add(ConsumerId id)
id
- public boolean remove(ConsumerId id)
id
- public Set<SubscriptionInfo> getDurableRemoteSubs()
public boolean isEmpty()
public int size()
public ConsumerInfo getLocalInfo()
public ConsumerInfo getRemoteInfo()
public void waitForCompletion()
public void decrementOutstandingResponses()
public boolean incrementOutstandingResponses()
public NetworkBridgeFilter getNetworkBridgeFilter()
public void setNetworkBridgeFilter(NetworkBridgeFilter networkBridgeFilter)
public SubscriptionInfo getLocalDurableSubscriber()
public void setLocalDurableSubscriber(SubscriptionInfo localDurableSubscriber)
public boolean isStaticallyIncluded()
public void setStaticallyIncluded(boolean staticallyIncluded)
Copyright © 2005–2018 FuseSource, Corp.. All rights reserved.