org.qbroker.persister

Class EventPersister

java.lang.Object

org.qbroker.persister.Persister

org.qbroker.persister.EventPersister

All Implemented Interfaces:

MessagePersister

public class EventPersister
extends Persister

EventPersister listens to an XQueue and receives ObjectMessages from it. The incomint message is supposed to contain a task Map. EventPersister completes the task and returns the message with updates.

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
EventPersister(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

EventPersister

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