org.qbroker.persister

Class FilePersister

java.lang.Object

org.qbroker.persister.Persister

org.qbroker.persister.FilePersister

All Implemented Interfaces:

MessagePersister

public class FilePersister
extends Persister

FilePersister listens to an XQueue and receives JMS Messages from the XQueue as the requests. Either it stores the JMS Messages on a remote service as files, or it downloads files from a remote service and loads the downloaded content to the messages. Currently, FilePersister supports various types of data stores, such as file, log, ftp, ftps, http, https, sftp and shell script. FilePersister also supports flow control and allows object control from its owner. It is fault tolerant with retry and idle options.

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
FilePersister(java.util.Map props)

Method Summary

Modifier and Type	Method and Description
void	close() closes all opened resources
void	execute(XQueue xq) It gets a JMS Message from the XQueue and executes the script retrieved from it continuously.
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

FilePersister

public FilePersister(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

execute

public void execute(XQueue xq)
             throws javax.jms.JMSException

It gets a JMS Message from the XQueue and executes the script retrieved from it continuously. If XAMode has XA_CLIENT bit enabled, the incoming message will be required to be writeable. In this case, the method will set a String property of the message specified by the RCField with the return code, indicating the status of the execution on the script. The requester is required to check the value of the property once it gets the message back. If the return code is 0, the execution is successful.

Throws:

javax.jms.JMSException

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