Kieker 1.12

kieker.monitoring.writer.filesystem
Class AbstractAsyncZipWriter

java.lang.Object
  extended by kieker.monitoring.writer.AbstractMonitoringWriter
      extended by kieker.monitoring.writer.AbstractAsyncWriter
          extended by kieker.monitoring.writer.filesystem.AbstractAsyncZipWriter
All Implemented Interfaces:
IMonitoringRecordReceiver, IMonitoringWriter
Direct Known Subclasses:
AsyncAsciiZipWriter, AsyncBinaryZipWriter

public abstract class AbstractAsyncZipWriter
extends AbstractAsyncWriter

Since:
1.7
Author:
Jan Waller

Field Summary
static java.lang.String CONFIG_BUFFER
          The name of the configuration determining the size of the buffer.
static java.lang.String CONFIG_COMPRESS_LEVEL
          The name of the configuration determining the compression level.
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_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
AbstractAsyncZipWriter(Configuration configuration)
           
 
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  AbstractZipWriterThread initWorker(IMonitoringController monitoringController, java.util.concurrent.BlockingQueue<IMonitoringRecord> writeQueue, StringMappingFileWriter strMappingFileWriter, java.lang.String path, int maxEntiresInFile, int bufferSize, int level)
           
 
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_BUFFER

public static final java.lang.String CONFIG_BUFFER
The name of the configuration determining the size of the buffer.

See Also:
Constant Field Values

CONFIG_COMPRESS_LEVEL

public static final java.lang.String CONFIG_COMPRESS_LEVEL
The name of the configuration determining the compression level.

See Also:
Constant Field Values
Constructor Detail

AbstractAsyncZipWriter

public AbstractAsyncZipWriter(Configuration configuration)
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!

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 AbstractZipWriterThread initWorker(IMonitoringController monitoringController,
                                                      java.util.concurrent.BlockingQueue<IMonitoringRecord> writeQueue,
                                                      StringMappingFileWriter strMappingFileWriter,
                                                      java.lang.String path,
                                                      int maxEntiresInFile,
                                                      int bufferSize,
                                                      int level)
                                               throws java.lang.Exception
Throws:
java.lang.Exception

Kieker 1.12

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