kieker.analysis.reader.filesystem
Class FSReaderCons

java.lang.Object
  kieker.analysis.reader.filesystem.FSReaderCons

All Implemented Interfaces:

IMonitoringRecordReceiver

public class FSReaderCons
extends Object
implements IMonitoringRecordReceiver

Author:

Andre van Hoorn

Constructor Summary

FSReaderCons(IMonitoringRecordReceiver master, String[] inputDirs, Collection<Class<? extends IMonitoringRecord>> readOnlyRecordsOfType)

Method Summary

boolean	execute()
boolean	newMonitoringRecord(IMonitoringRecord monitoringRecord) Threads executing this method (concurrently) put record into sorted buffer, notify the buffer consumer and block until they are granted to read the next record.

Methods inherited from class java.lang.Object

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

Constructor Detail

FSReaderCons

public FSReaderCons(IMonitoringRecordReceiver master,
                    String[] inputDirs,
                    Collection<Class<? extends IMonitoringRecord>> readOnlyRecordsOfType)

Method Detail

newMonitoringRecord

public boolean newMonitoringRecord(IMonitoringRecord monitoringRecord)

Threads executing this method (concurrently) put record into sorted buffer, notify the buffer consumer and block until they are granted to read the next record.

Specified by:

newMonitoringRecord in interface IMonitoringRecordReceiver

Parameters:

monitoringRecord - the record.

Returns:

true on success; false in case of an error.

execute

public boolean execute()
                throws MonitoringRecordConsumerException

Throws:

MonitoringRecordConsumerException