Kieker 1.2

kieker.monitoring.writer.jms
Class JMSWriterThread<T>

java.lang.Object
  extended by java.lang.Thread
      extended by kieker.monitoring.writer.util.async.AbstractWorkerThread
          extended by kieker.monitoring.writer.jms.JMSWriterThread<T>
All Implemented Interfaces:
Runnable

public final class JMSWriterThread<T>
extends AbstractWorkerThread

The writer moves monitoring data via messaging to a JMS server. This uses the publishRecord/subscribe pattern. The JMS server will only keep each monitoring event for messageTimeToLive milliseconds presents before it is deleted. At the moment, JmsWorkers do not share any connections, sessions or other objects. History: 2008-09-13: Initial prototype

Author:
Matthias Rohr

Nested Class Summary
 
Nested classes/interfaces inherited from class java.lang.Thread
Thread.State, Thread.UncaughtExceptionHandler
 
Field Summary
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
JMSWriterThread(BlockingQueue<T> writeQueue, T endOfMonitoringMarker, String contextFactoryType, String providerUrl, String factoryLookupName, String topic, long messageTimeToLive)
           
 
Method Summary
 void initShutdown()
          Initials the shutdown
 boolean isFinished()
          initShutdown has to be called before isFinished will result in true.
 void run()
           
 
Methods inherited from class kieker.monitoring.writer.util.async.AbstractWorkerThread
isWriteRecordTypeIds, setWriteRecordTypeIds
 
Methods inherited from class java.lang.Thread
activeCount, checkAccess, 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, toString, yield
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

JMSWriterThread

public JMSWriterThread(BlockingQueue<T> writeQueue,
                       T endOfMonitoringMarker,
                       String contextFactoryType,
                       String providerUrl,
                       String factoryLookupName,
                       String topic,
                       long messageTimeToLive)
Method Detail

run

public void run()
Specified by:
run in interface Runnable
Overrides:
run in class Thread

isFinished

public boolean isFinished()
Description copied from class: AbstractWorkerThread
initShutdown has to be called before isFinished will result in true. IsFinished == true means that the worker does not have additional jobs in it's queue and won't accept new jobs.

Specified by:
isFinished in class AbstractWorkerThread

initShutdown

public void initShutdown()
Initials the shutdown

Specified by:
initShutdown in class AbstractWorkerThread

Kieker 1.2

Copyright 2010 the Kieker Project, http://kieker.sourceforge.net