Kieker 1.12

kieker.monitoring.writer.filesystem
Class AsyncFsWriter

java.lang.Object
  extended by kieker.monitoring.writer.AbstractMonitoringWriter
      extended by kieker.monitoring.writer.AbstractAsyncWriter
          extended by kieker.monitoring.writer.filesystem.AbstractAsyncFSWriter
              extended by kieker.monitoring.writer.filesystem.AsyncFsWriter
All Implemented Interfaces:
IMonitoringRecordReceiver, IMonitoringWriter

public final class AsyncFsWriter
extends AbstractAsyncFSWriter

Since:
< 0.9
Author:
Matthias Rohr, Robert von Massow, Andre van Hoorn, Jan Waller

Field Summary
static java.lang.String CONFIG_BUFFER
           
static java.lang.String CONFIG_FLUSH
           
 
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
AsyncFsWriter(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_FLUSH

public static final java.lang.String CONFIG_FLUSH

CONFIG_BUFFER

public static final java.lang.String CONFIG_BUFFER
Constructor Detail

AsyncFsWriter

public AsyncFsWriter(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

Kieker 1.12

Copyright 2015 Kieker Project, http://kieker-monitoring.net