public class DemandSubscription extends Object
Modifier and Type | Method and 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() |
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 boolean addForcedDurableConsumer(ConsumerId id)
public boolean removeForcedDurableConsumer(ConsumerId id)
public int getForcedDurableConsumersSize()
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–2019 The Apache Software Foundation. All rights reserved.