public class BufferingChangeModel extends Object implements ChangeModel
Modifier and Type | Class and Description |
---|---|
static interface |
BufferingChangeModel.Context |
Constructor and Description |
---|
BufferingChangeModel(BufferingChangeModel.Context context,
ScheduledExecutorService executor,
long flushDelay)
Create a new buffering change model
|
Modifier and Type | Method and Description |
---|---|
Runnable |
dispose() |
void |
notifyChange(ASDUAddress asduAddress,
InformationObjectAddress informationObjectAddress,
Value<?> value) |
public BufferingChangeModel(BufferingChangeModel.Context context, ScheduledExecutorService executor, long flushDelay)
executor
- a single threaded scheduled executorflushDelay
- the minimum delay between flushespublic void notifyChange(ASDUAddress asduAddress, InformationObjectAddress informationObjectAddress, Value<?> value)
notifyChange
in interface ChangeModel
public Runnable dispose()
dispose
in interface ChangeModel