org.eclipse.neoscada.protocol.iec60870.server.data.model

Class BufferingChangeModel

java.lang.Object

org.eclipse.neoscada.protocol.iec60870.server.data.model.BufferingChangeModel

All Implemented Interfaces:

ChangeModel

public class BufferingChangeModel
extends Object
implements ChangeModel

This is a change model which sends out aggregated change events

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	BufferingChangeModel.Context

Constructor Summary

Constructors

Constructor and Description
BufferingChangeModel(BufferingChangeModel.Context context, ScheduledExecutorService executor, long flushDelay) Create a new buffering change model

Method Summary

Modifier and Type	Method and Description
Runnable	dispose()
void	notifyChange(ASDUAddress asduAddress, InformationObjectAddress informationObjectAddress, Value<?> value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BufferingChangeModel

public BufferingChangeModel(BufferingChangeModel.Context context,
                            ScheduledExecutorService executor,
                            long flushDelay)

Create a new buffering change model

Parameters:

executor - a single threaded scheduled executor

flushDelay - the minimum delay between flushes

Method Detail

notifyChange

public void notifyChange(ASDUAddress asduAddress,
                         InformationObjectAddress informationObjectAddress,
                         Value<?> value)

Specified by:

notifyChange in interface ChangeModel

dispose

public Runnable dispose()

Specified by:

dispose in interface ChangeModel