org.qbroker.persister

Class JobPersister

java.lang.Object

org.qbroker.persister.Persister

org.qbroker.persister.JobPersister

All Implemented Interfaces:

MessagePersister

public class JobPersister
extends Persister

JobPersister listens to an XQueue and receives JMS Messages as the job requests. There are two types job requests. The first one is the init request with complete job information. The other is the request on the current job such as a query of the progress data or a command to abort the job, etc. Once the persister gets a job init message, it will initialize the job and starts to process it. Usually, it takes a while to process a job request. While the job is running, the persister is also listening to the XQueue for messages. The most common messages are the queries for progress data on the job. In this case, the persister will load the progress data to the message and removes it from the queue. If the request is to abort the running job, the persister will abort the job and resets the return code. The message will be removed from the queue. In case the message is another job init request while a job is running, the persister will just reset the error code on the message and removes it from the queue. Once the job is done, the job init message will be acknowledged and removed from the queue.

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
JobPersister(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) gets all the JMS messages from the XQueue and delivers them to their destinations.

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

JobPersister

public JobPersister(java.util.Map props)

Method Detail

persist

public void persist(XQueue xq,
                    int baseTime)

Description copied from interface: MessagePersister

gets all the JMS messages from the XQueue and delivers them to their destinations. In case of failure, it should keep retry with the sleepTime in milliseconds.

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