kieker.monitoring.writer.filesystem
Class AsyncBinaryNFsWriter

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

All Implemented Interfaces:

IMonitoringRecordReceiver, IMonitoringWriter

public final class AsyncBinaryNFsWriter
extends AbstractAsyncFSWriter

Since:

1.9

Author:

Jan Waller

Field Summary

static java.lang.String	CONFIG_BUFFER
static java.lang.String	CONFIG_COMPRESS

Fields inherited from class kieker.monitoring.writer.filesystem.AbstractAsyncFSWriter

CONFIG_MAXENTRIESINFILE, CONFIG_MAXLOGFILES, CONFIG_MAXLOGSIZE, CONFIG_PATH

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

AsyncBinaryNFsWriter(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 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.filesystem.AbstractAsyncFSWriter

init

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_BUFFER

public static final java.lang.String CONFIG_BUFFER

CONFIG_COMPRESS

public static final java.lang.String CONFIG_COMPRESS

Constructor Detail

AsyncBinaryNFsWriter

public AsyncBinaryNFsWriter(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 AbstractAsyncFSWriter

Returns:

The configuration object containing the default configuration.

initWorker

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

Specified by:

initWorker in class AbstractAsyncFSWriter