kieker.monitoring.writer.filesystem
Class AsyncBinaryZipWriter

java.lang.Object
  kieker.monitoring.writer.AbstractMonitoringWriter
      kieker.monitoring.writer.AbstractAsyncWriter
          kieker.monitoring.writer.filesystem.AbstractAsyncZipWriter
              kieker.monitoring.writer.filesystem.AsyncBinaryZipWriter

All Implemented Interfaces:

IMonitoringRecordReceiver, IMonitoringWriter

public final class AsyncBinaryZipWriter
extends AbstractAsyncZipWriter

Since:

1.7

Author:

Jan Waller

Field Summary

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

CONFIG_BUFFER, CONFIG_COMPRESS_LEVEL, CONFIG_MAXENTRIESINFILE, 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

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

Method Summary

protected AbstractZipWriterThread

initWorker(IMonitoringController monitoringController, java.util.concurrent.BlockingQueue<IMonitoringRecord> writeQueue, StringMappingFileWriter mappingFileWriter, java.lang.String path, int maxEntiresInFile, int bufferSize, int level)

Methods inherited from class kieker.monitoring.writer.filesystem.AbstractAsyncZipWriter

getDefaultConfiguration, 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

Constructor Detail

AsyncBinaryZipWriter

public AsyncBinaryZipWriter(Configuration configuration)
                     throws java.io.IOException

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

Parameters:

configuration - The configuration for this writer.

Throws:

java.io.IOException - If something went wrong during the initialization of the writer.

Method Detail

initWorker

protected AbstractZipWriterThread initWorker(IMonitoringController monitoringController,
                                             java.util.concurrent.BlockingQueue<IMonitoringRecord> writeQueue,
                                             StringMappingFileWriter mappingFileWriter,
                                             java.lang.String path,
                                             int maxEntiresInFile,
                                             int bufferSize,
                                             int level)
                                      throws java.lang.Exception

Specified by:

initWorker in class AbstractAsyncZipWriter

Throws:

java.lang.Exception