kieker.monitoring.writer.filesystem
Class AsyncFsWriter

java.lang.Object
  kieker.monitoring.writer.filesystem.AsyncFsWriter

All Implemented Interfaces:

IMonitoringRecordReceiver, IMonitoringLogWriter

public final class AsyncFsWriter
extends Object
implements IMonitoringLogWriter

Author:

Matthias Rohr, Andre van Hoorn

Constructor Summary

AsyncFsWriter()

AsyncFsWriter(String storagePathBase, int asyncRecordQueueSize, boolean blockOnFullQueue)

Method Summary

String	getFilenamePrefix()
String	getInfoString() Returns a human-readable information string about the writer's configuration and state.
Vector<AbstractWorkerThread>	getWorkers() Returns a vector of workers, or null if none.
boolean	init(String initString) Initialize instance from passed initialization string which is typically a list of separated parameter/values pairs.
boolean	newMonitoringRecord(IMonitoringRecord monitoringRecord) This method is not synchronized.

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncFsWriter

public AsyncFsWriter()

AsyncFsWriter

public AsyncFsWriter(String storagePathBase,
                     int asyncRecordQueueSize,
                     boolean blockOnFullQueue)

Method Detail

init

public boolean init(String initString)

Description copied from interface: IMonitoringLogWriter

Initialize instance from passed initialization string which is typically a list of separated parameter/values pairs. The implementing class AbstractMonitoringLogWriter includes convenient methods to extract configuration values from an initString.

Specified by:

init in interface IMonitoringLogWriter

Parameters:

initString - the initialization string

Returns:

true iff the initialiation was successful

getWorkers

public Vector<AbstractWorkerThread> getWorkers()

Description copied from interface: IMonitoringLogWriter

Returns a vector of workers, or null if none.

Specified by:

getWorkers in interface IMonitoringLogWriter

newMonitoringRecord

public boolean newMonitoringRecord(IMonitoringRecord monitoringRecord)

This method is not synchronized.

Specified by:

newMonitoringRecord in interface IMonitoringRecordReceiver

Parameters:

monitoringRecord - the record.

Returns:

true on success; false in case of an error.

getFilenamePrefix

public String getFilenamePrefix()

getInfoString

public String getInfoString()

Description copied from interface: IMonitoringLogWriter

Returns a human-readable information string about the writer's configuration and state.

Specified by:

getInfoString in interface IMonitoringLogWriter

Returns:

the information string.