public class ChannelAgent extends SourceAgent<ChannelTimeRecord>
Modifier and Type | Class and Description |
---|---|
protected class |
ChannelAgent.EventHandler
Handle the monitor events
|
protected class |
ChannelAgent.FilteredEventHandler
Handle the Monitor events and filter the events according to the supplied
ChannelRecordFilter . |
_binUpdateProxy
Constructor and Description |
---|
ChannelAgent(MessageCenter localCenter,
Channel newChannel,
java.lang.String newName,
RecordFilter<ChannelTimeRecord> recordFilter,
CorrelationTester<ChannelTimeRecord> tester)
Creates new ChannelAgent
|
Modifier and Type | Method and Description |
---|---|
boolean |
isActive()
Determine if the channel is actively being monitored.
|
boolean |
isEnabled()
Determine if the channel is enabled for correlations.
|
protected void |
makeMonitor()
Create a monitor to listen for new channel records.
|
protected void |
setupEventHandler(RecordFilter<ChannelTimeRecord> recordFilter)
Setup the event handler to use the specified record filter to filter
monitor events for this channel.
|
boolean |
startMonitor()
Start monitoring the channel.
|
void |
stopMonitor()
Stop monitoring the channel
|
binTimespanChanged, correlationFilterChanged, name, postEvent, reset, setBinTimespan, shutdown, sourceAdded, sourceRemoved, willStartMonitoring, willStopMonitoring
public ChannelAgent(MessageCenter localCenter, Channel newChannel, java.lang.String newName, RecordFilter<ChannelTimeRecord> recordFilter, CorrelationTester<ChannelTimeRecord> tester)
localCenter
- local shared message centernewChannel
- channel to monitornewName
- namerecordFilter
- filter for recordstester
- correlation testerprotected void setupEventHandler(RecordFilter<ChannelTimeRecord> recordFilter)
setupEventHandler
in class SourceAgent<ChannelTimeRecord>
recordFilter
- The filter to use for this channel.SourceAgent.postEvent(RecordType, double)
public boolean isEnabled()
public boolean isActive()
public boolean startMonitor()
startMonitor
in class SourceAgent<ChannelTimeRecord>
public void stopMonitor()
stopMonitor
in class SourceAgent<ChannelTimeRecord>
protected void makeMonitor()