public class SubscriptionList
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private long |
_dataIndexSubscriptionTime |
private static Debug |
_debug |
private ReceivingSubscription |
_drain |
private java.util.Set<ReceivingSubscription> |
_receivingSubscriptions |
private java.util.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() |
java.util.Collection<ReceivingSubscription> |
getReceivingSubscriptions() |
java.util.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) |
java.lang.String |
toString() |
private static final Debug _debug
private final java.util.Set<SendingSubscription> _sendingSubscriptions
private final java.util.Set<ReceivingSubscription> _receivingSubscriptions
private ReceivingSubscription _drain
private SendingSubscription _source
private long _dataIndexSubscriptionTime
public java.lang.String toString()
toString
in class java.lang.Object
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 java.util.Collection<SendingSubscription> getSendingSubscriptions()
public java.util.Collection<ReceivingSubscription> getReceivingSubscriptions()
public boolean isEmpty()
public boolean isCentralDistributor()
public long getDataIndex(long runningNumber)
public long getCentralDistributorId()