kieker.monitoring.writer.filesystem
Class AbstractAsyncFSWriter

java.lang.Object
  kieker.monitoring.writer.AbstractMonitoringWriter
      kieker.monitoring.writer.AbstractAsyncWriter
          kieker.monitoring.writer.filesystem.AbstractAsyncFSWriter

All Implemented Interfaces:

IMonitoringRecordReceiver, IMonitoringWriter

Direct Known Subclasses:

AsyncBinaryFsWriter, AsyncBinaryNFsWriter, AsyncFsWriter

public abstract class AbstractAsyncFSWriter
extends AbstractAsyncWriter

Since:

1.5

Author:

Matthias Rohr, Robert von Massow, Andre van Hoorn, Jan Waller

Field Summary

static java.lang.String	CONFIG_MAXENTRIESINFILE The name of the configuration determining the maximal number of entries in a file.
static java.lang.String	CONFIG_MAXLOGFILES The name of the configuration determining the maximal number of log files.
static java.lang.String	CONFIG_MAXLOGSIZE The name of the configuration determining the maximal size of the files in MiB.
static java.lang.String	CONFIG_PATH The name of the configuration for the custom storage path if the writer is advised not to store in the temporary directory.

Fields inherited from class kieker.monitoring.writer.AbstractAsyncWriter

blockingQueue, CONFIG_BEHAVIOR, CONFIG_PRIORITIZED_QUEUESIZE, CONFIG_QUEUESIZE, CONFIG_SHUTDOWNDELAY, prioritizedBlockingQueue

Fields inherited from class kieker.monitoring.writer.AbstractMonitoringWriter

monitoringController

Constructor Summary

protected

AbstractAsyncFSWriter(Configuration configuration) Creates a new instance of this class using the given parameters.

Method Summary

protected Configuration	getDefaultConfiguration() This method should be overwritten, iff the writer is external to Kieker and thus its default configuration is not included in the default config file.
protected void	init() Implementing classes should indicate an initialization error by throwing an Exception.
protected abstract AbstractFsWriterThread	initWorker(IMonitoringController monitoringController, java.util.concurrent.BlockingQueue<IMonitoringRecord> writeQueue, MappingFileWriter mappingFileWriter, java.lang.String path, int maxEntiresInFile, int maxlogSize, int maxLogFiles)

Methods inherited from class kieker.monitoring.writer.AbstractAsyncWriter

addWorker, newMonitoringRecord, newMonitoringRecordNonBlocking, terminate, toString

Methods inherited from class kieker.monitoring.writer.AbstractMonitoringWriter

setController

Methods inherited from class java.lang.Object

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

Field Detail

CONFIG_PATH

public static final java.lang.String CONFIG_PATH

The name of the configuration for the custom storage path if the writer is advised not to store in the temporary directory.

See Also:

Constant Field Values

CONFIG_MAXENTRIESINFILE

public static final java.lang.String CONFIG_MAXENTRIESINFILE

The name of the configuration determining the maximal number of entries in a file.

See Also:

Constant Field Values

CONFIG_MAXLOGSIZE

public static final java.lang.String CONFIG_MAXLOGSIZE

The name of the configuration determining the maximal size of the files in MiB.

See Also:

Constant Field Values

CONFIG_MAXLOGFILES

public static final java.lang.String CONFIG_MAXLOGFILES

The name of the configuration determining the maximal number of log files.

See Also:

Constant Field Values

Constructor Detail

AbstractAsyncFSWriter

protected AbstractAsyncFSWriter(Configuration configuration)

Creates a new instance of this class using the given parameters.

Parameters:

configuration - The configuration for this writer.

Method Detail

getDefaultConfiguration

protected Configuration getDefaultConfiguration()

This method should be overwritten, iff the writer is external to Kieker and thus its default configuration is not included in the default config file. Make sure that the three required properties always have default values! Make sure that the required properties always have default values!

Overrides:

getDefaultConfiguration in class AbstractAsyncWriter

Returns:

The configuration object containing the default configuration.

init

protected final void init()
                   throws java.lang.Exception

Description copied from class: AbstractMonitoringWriter

Implementing classes should indicate an initialization error by throwing an Exception.

Specified by:

init in class AbstractMonitoringWriter

Throws:

java.lang.Exception - If something during the initialization went wrong.

initWorker

protected abstract AbstractFsWriterThread initWorker(IMonitoringController monitoringController,
                                                     java.util.concurrent.BlockingQueue<IMonitoringRecord> writeQueue,
                                                     MappingFileWriter mappingFileWriter,
                                                     java.lang.String path,
                                                     int maxEntiresInFile,
                                                     int maxlogSize,
                                                     int maxLogFiles)