kieker.monitoring.writer.filesystem.async
Class AsciiZipWriterThread

java.lang.Object
  java.lang.Thread
      kieker.monitoring.writer.AbstractAsyncThread
          kieker.monitoring.writer.filesystem.async.AbstractZipWriterThread
              kieker.monitoring.writer.filesystem.async.AsciiZipWriterThread

All Implemented Interfaces:

java.lang.Runnable

public class AsciiZipWriterThread
extends AbstractZipWriterThread

Since:

1.7

Author:

Jan Waller

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class kieker.monitoring.writer.filesystem.async.AbstractZipWriterThread

fileExtension, zipOutputStream

Fields inherited from class kieker.monitoring.writer.AbstractAsyncThread

monitoringController

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

AsciiZipWriterThread(IMonitoringController monitoringController, java.util.concurrent.BlockingQueue<IMonitoringRecord> writeQueue, StringMappingFileWriter mappingFileWriter, java.lang.String path, int maxEntriesInFile, int bufferSize, int level)
Create a new AsciiZipWriterThread.

Method Summary

protected void	cleanupFinal() Inheriting classes should implement this method to perform a final cleanup.
protected void	cleanupForNextEntry() Inheriting classes should implement this method to perform a cleanup for the next entry.
protected void	write(IMonitoringRecord monitoringRecord) Inheriting classes should implement this method to actually write the monitoring record.

Methods inherited from class kieker.monitoring.writer.filesystem.async.AbstractZipWriterThread

cleanup, consume, getFilename, toString

Methods inherited from class kieker.monitoring.writer.AbstractAsyncThread

initShutdown, isFinished, run

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

AsciiZipWriterThread

public AsciiZipWriterThread(IMonitoringController monitoringController,
                            java.util.concurrent.BlockingQueue<IMonitoringRecord> writeQueue,
                            StringMappingFileWriter mappingFileWriter,
                            java.lang.String path,
                            int maxEntriesInFile,
                            int bufferSize,
                            int level)
                     throws java.io.IOException

Create a new AsciiZipWriterThread.

Parameters:

monitoringController - the monitoring controller accessed by this thread

writeQueue - the queue where the writer fetches its records from

mappingFileWriter - writer for the mapping file (the file where class names are mapped to record ids)

path - location where to files should go to (the path must point to a directory)

maxEntriesInFile - limit for the number of records per log file

bufferSize - size of the output buffer

level - compression level

Throws:

java.io.IOException - when file operation fails

Method Detail

write

protected void write(IMonitoringRecord monitoringRecord)
              throws java.io.IOException

Description copied from class: AbstractZipWriterThread

Inheriting classes should implement this method to actually write the monitoring record.

Specified by:

write in class AbstractZipWriterThread

Parameters:

monitoringRecord - The record to be written.

Throws:

java.io.IOException - If something went wrong during the writing.

cleanupForNextEntry

protected void cleanupForNextEntry()
                            throws java.io.IOException

Description copied from class: AbstractZipWriterThread

Inheriting classes should implement this method to perform a cleanup for the next entry.

Specified by:

cleanupForNextEntry in class AbstractZipWriterThread

Throws:

java.io.IOException - If something went wrong during the cleanup.

cleanupFinal

protected void cleanupFinal()
                     throws java.io.IOException

Description copied from class: AbstractZipWriterThread

Inheriting classes should implement this method to perform a final cleanup.

Specified by:

cleanupFinal in class AbstractZipWriterThread

Throws:

java.io.IOException - If something went wrong during the cleanup.