public class FilePersister extends Persister
capacity, displayMask, linkName, maxRetry, operation, partition, pauseTime, propertyName, repeatPeriod, standbyTime, status, timeout, tolerance, uri, waitTime, xaMode
PSTR_CLOSED, PSTR_DISABLED, PSTR_PAUSE, PSTR_READY, PSTR_RETRYING, PSTR_RUNNING, PSTR_STANDBY, PSTR_STOPPED
Constructor and Description |
---|
FilePersister(java.util.Map props) |
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.
|
getCapacity, getLinkName, getName, getOperation, getStatus, getXAMode, isStopped, keepRunning, resetStatus, setStatus
public void persist(XQueue xq, int baseTime)
MessagePersister
persist
in interface MessagePersister
persist
in class Persister
public void execute(XQueue xq) throws javax.jms.JMSException
javax.jms.JMSException
public void close()
MessagePersister
close
in interface MessagePersister
close
in class Persister
protected void finalize()
finalize
in class java.lang.Object