public abstract class AbstractBaseDataModel extends Object implements DataModel
Modifier and Type | Field and Description |
---|---|
protected com.google.common.util.concurrent.ListeningScheduledExecutorService |
executor |
Constructor and Description |
---|
AbstractBaseDataModel(String threadName) |
Modifier and Type | Method and Description |
---|---|
void |
dispose() |
void |
disposeAndWait() |
protected com.google.common.util.concurrent.ListenableFuture<Void> |
disposeSubscription(DefaultSubscription subscription) |
protected int |
getNumberOfSubscriptions() |
protected void |
notifyChangeBoolean(ASDUAddress asduAddress,
InformationObjectAddress startAddress,
List<Value<Boolean>> values) |
protected void |
notifyChangeBoolean(ASDUAddress asduAddress,
List<InformationEntry<Boolean>> values) |
protected void |
notifyChangeFloat(ASDUAddress asduAddress,
InformationObjectAddress startAddress,
List<Value<Float>> values) |
protected void |
notifyChangeFloat(ASDUAddress asduAddress,
List<InformationEntry<Float>> values) |
Subscription |
subscribe(DataListener listener) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createBackgroundIterator, forAllAsdu, read, readAll, writeCommand, writeScaledValue, writeValue
protected final com.google.common.util.concurrent.ListeningScheduledExecutorService executor
public AbstractBaseDataModel(String threadName)
public Subscription subscribe(DataListener listener)
protected int getNumberOfSubscriptions()
protected com.google.common.util.concurrent.ListenableFuture<Void> disposeSubscription(DefaultSubscription subscription)
protected void notifyChangeBoolean(ASDUAddress asduAddress, InformationObjectAddress startAddress, List<Value<Boolean>> values)
protected void notifyChangeBoolean(ASDUAddress asduAddress, List<InformationEntry<Boolean>> values)
protected void notifyChangeFloat(ASDUAddress asduAddress, InformationObjectAddress startAddress, List<Value<Float>> values)
protected void notifyChangeFloat(ASDUAddress asduAddress, List<InformationEntry<Float>> values)
public void disposeAndWait() throws InterruptedException
InterruptedException