public class SubscriptionList extends Object
Modifier and Type | Field and Description |
---|---|
private long |
_dataIndexSubscriptionTime |
private static Debug |
_debug |
private ReceivingSubscription |
_drain |
private Set<ReceivingSubscription> |
_receivingSubscriptions |
private Set<SendingSubscription> |
_sendingSubscriptions |
private SendingSubscription |
_source |
Constructor and Description |
---|
SubscriptionList() |
Modifier and Type | Method and Description |
---|---|
void |
addReceiver(ReceivingSubscription receivingSubscription) |
void |
addSender(SendingSubscription sendingSubscription) |
boolean |
canSetDrain(ReceivingSubscription receivingSubscription) |
boolean |
canSetSource(SendingSubscription sendingSubscription) |
long |
getCentralDistributorId() |
long |
getDataIndex(long runningNumber) |
ReceivingSubscription |
getDrain() |
Collection<ReceivingSubscription> |
getReceivingSubscriptions() |
Collection<SendingSubscription> |
getSendingSubscriptions() |
SendingSubscription |
getSource() |
boolean |
hasDrain() |
boolean |
hasDrainOrSource() |
boolean |
hasSource() |
boolean |
isCentralDistributor() |
boolean |
isEmpty() |
void |
removeReceiver(ReceivingSubscription receivingSubscription) |
void |
removeSender(SendingSubscription sendingSubscription) |
void |
setDrain(ReceivingSubscription drain) |
void |
setSource(SendingSubscription source) |
String |
toString() |
private static final Debug _debug
private final Set<SendingSubscription> _sendingSubscriptions
private final Set<ReceivingSubscription> _receivingSubscriptions
private ReceivingSubscription _drain
private SendingSubscription _source
private long _dataIndexSubscriptionTime
public boolean hasSource()
public boolean hasDrain()
public ReceivingSubscription getDrain()
public SendingSubscription getSource()
public void setDrain(ReceivingSubscription drain)
public void setSource(SendingSubscription source)
public void addReceiver(ReceivingSubscription receivingSubscription)
public void addSender(SendingSubscription sendingSubscription)
public void removeReceiver(ReceivingSubscription receivingSubscription)
public void removeSender(SendingSubscription sendingSubscription)
public boolean canSetSource(SendingSubscription sendingSubscription)
public boolean canSetDrain(ReceivingSubscription receivingSubscription)
public boolean hasDrainOrSource()
public Collection<SendingSubscription> getSendingSubscriptions()
public Collection<ReceivingSubscription> getReceivingSubscriptions()
public boolean isEmpty()
public boolean isCentralDistributor()
public long getDataIndex(long runningNumber)
public long getCentralDistributorId()