org.qbroker.persister

Class JMXPersister

java.lang.Object

org.qbroker.persister.Persister

org.qbroker.persister.JMXPersister

All Implemented Interfaces:

MessagePersister

public class JMXPersister
extends Persister

JMXPersister listens to an XQueue and receives JMS messages from it. It converts each JMS Message into a JMX request and sends the request to the specified JMX Service. Once it gets the response back, the content of the response will be put into the message body as the response.

Currently, it only supports PCF, IMQ, QMF and JMX requests by default. It also supports customized plugins via PluginClassName and Operation. The plugin is supposed to implement org.qbroker.common.Connector and the name of the method to be invoked must be same as the value of Operation. JMXPersister only knows how to handle TimeoutException, JMSException and JMException. TimeoutException is for hibernate, JMSException for failures on message operations, JMException for failures related to the remote datasource, such as network issue, service not available, etc. Therefore, if JMException is caught, JMXPersister will keep retrying until either the failure is resolved or the flow is paused.

Author:

yannanlu@yahoo.com

Field Summary

Fields inherited from class org.qbroker.persister.Persister

capacity, displayMask, linkName, maxRetry, operation, partition, pauseTime, propertyName, repeatPeriod, standbyTime, status, timeout, tolerance, uri, waitTime, xaMode

Fields inherited from interface org.qbroker.persister.MessagePersister

PSTR_CLOSED, PSTR_DISABLED, PSTR_PAUSE, PSTR_READY, PSTR_RETRYING, PSTR_RUNNING, PSTR_STANDBY, PSTR_STOPPED

Constructor Summary

Constructors

Constructor and Description
JMXPersister(java.util.Map props)

Method Summary

Modifier and Type	Method and Description
void	close() closes all opened resources
protected void	finalize()
void	persist(XQueue xq, int baseTime) implementation of persist() with flow control individual object control will be provided by the owner

Methods inherited from class org.qbroker.persister.Persister

getCapacity, getLinkName, getName, getOperation, getStatus, getXAMode, isStopped, keepRunning, resetStatus, setStatus

Methods inherited from class java.lang.Object

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

Constructor Detail

JMXPersister

public JMXPersister(java.util.Map props)

Method Detail

persist

public void persist(XQueue xq,
                    int baseTime)

implementation of persist() with flow control individual object control will be provided by the owner

Specified by:

persist in interface MessagePersister

Specified by:

persist in class Persister

close

public void close()

Description copied from interface: MessagePersister

closes all opened resources

Specified by:

close in interface MessagePersister

Specified by:

close in class Persister

finalize

protected void finalize()

Overrides:

finalize in class java.lang.Object