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, willStopMonitoringpublic 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()