kieker.monitoring.writer.jms
Class AsyncJMSWriter

java.lang.Object
  kieker.monitoring.writer.jms.AsyncJMSWriter

All Implemented Interfaces:

IMonitoringRecordReceiver, IMonitoringLogWriter

public final class AsyncJMSWriter
extends Object
implements IMonitoringLogWriter

Author:

Matthias Rohr, Andre van Hoorn

Constructor Summary

AsyncJMSWriter()

Method Summary

String	getInfoString() Returns a human-readable information string about the writer's configuration and state.
Vector<AbstractWorkerThread>	getWorkers() Returns a vector of workers, or null if none.
boolean	init(String initString) Init String.
boolean	newMonitoringRecord(IMonitoringRecord monitoringRecord) Called for each new record.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AsyncJMSWriter

public AsyncJMSWriter()

Method Detail

init

public boolean init(String initString)

Init String. Expect key=value pairs separated by |. Example initString (meaning of keys explained below): jmsProviderUrl=tcp://localhost:3035/ | jmsTopic=queue1 | jmsContextFactoryType=org.exolab.jms.jndi.InitialContextFactory | jmsFactoryLookupName=ConnectionFactory | jmsMessageTimeToLive = 10000 jmsContextFactoryType -- type of the jms factory implementation, e.g. "org.exolab.jms.jndi.InitialContextFactory" for openjms 0.7.7 jmsProviderUrl -- url of the jndi provider that knows the jms service jmsFactoryLookupName -- service name for the jms connection factory jmsTopic -- topic at the jms server which is used in the publisher/subscribe communication jmsMessageTimeToLive -- time that a jms message will kepts be alive at the jms server before it is automatically deleted

Specified by:

init in interface IMonitoringLogWriter

Parameters:

initString -

Returns:

true on success. false on error.

getInfoString

public String getInfoString()

Description copied from interface: IMonitoringLogWriter

Returns a human-readable information string about the writer's configuration and state.

Specified by:

getInfoString in interface IMonitoringLogWriter

Returns:

the information string.

newMonitoringRecord

public boolean newMonitoringRecord(IMonitoringRecord monitoringRecord)

Description copied from interface: IMonitoringRecordReceiver

Called for each new record. Notice, that this method should not throw an exception, but indicate an error by the return value false.

Specified by:

newMonitoringRecord in interface IMonitoringRecordReceiver

Parameters:

monitoringRecord - the record.

Returns:

true on success; false in case of an error.

getWorkers

public Vector<AbstractWorkerThread> getWorkers()

Description copied from interface: IMonitoringLogWriter

Returns a vector of workers, or null if none.

Specified by:

getWorkers in interface IMonitoringLogWriter