public class DemandSubscription extends Object
Modifier and Type | Method and Description |
---|---|
boolean |
add(ConsumerId id)
Increment the consumers associated with this subscription
|
void |
decrementOutstandingResponses() |
ConsumerInfo |
getLocalInfo() |
NetworkBridgeFilter |
getNetworkBridgeFilter() |
ConsumerInfo |
getRemoteInfo() |
boolean |
incrementOutstandingResponses() |
boolean |
isEmpty() |
boolean |
remove(ConsumerId id)
Increment the consumers associated with this subscription
|
void |
setNetworkBridgeFilter(NetworkBridgeFilter networkBridgeFilter) |
int |
size() |
void |
waitForCompletion() |
public boolean add(ConsumerId id)
id
- public boolean remove(ConsumerId id)
id
- 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)
Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.