org.qbroker.persister

Class Persister

java.lang.Object

org.qbroker.persister.Persister

All Implemented Interfaces:

MessagePersister

Direct Known Subclasses:

AWSRequester, DocumentPersister, EventPersister, FilePersister, JDBCPersister, JMSPersister, JMSPublisher, JMXPersister, JobPersister, LogPersister, MessageEvaluator, MessageTerminator, MonitorPersister, PacketPersister, PersisterPool, ReceiverPool, RedisPersister, RMQPersister, ServerPersister, StreamPersister

public abstract class Persister
extends java.lang.Object
implements MessagePersister

Persister is an abstract class of MessagePersister.

tolerance: not used
maxRetry: number of times to reconnect in one period
repeatPeriod: quietPeriod + maxRetry, period of repeat operation
pauseTime: sleepTime in millisec for PAUSE state or default baseTime
standbyTime: sleepTime in millisec for STANDBY state or reconnect action
timeout: timeout in millisec to reset retryCount for a new session
waitTime: sleep time in millisec for disable action

PSTR_READY connected and ready to work
PSTR_RUNNING running normally
PSTR_RETRYING trying to get back to running state
PSTR_PAUSE pausing for a bit while still connected
PSTR_STANDBY standby for a bit longer while still connected
PSTR_DISABLED connection closed but still standby
PSTR_STOPPED completed the job and closed all connections
PSTR_CLOSED closed all connections and ready to destroy object

Author:

yannanlu@yahoo.com

Field Summary

Fields

Modifier and Type	Field and Description
protected int	capacity
protected int	displayMask
protected java.lang.String	linkName
protected int	maxRetry
protected java.lang.String	operation
protected int[]	partition
protected int	pauseTime
protected java.lang.String[]	propertyName
protected int	repeatPeriod
protected int	standbyTime
protected int	status
protected int	timeout
protected int	tolerance
protected java.lang.String	uri
protected long	waitTime
protected int	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
Persister(java.util.Map props)

Method Summary

Modifier and Type	Method and Description
abstract void	close() closes all opened resources
int	getCapacity() returns the capacity of the InLink
java.lang.String	getLinkName() returns the name of the InLink
java.lang.String	getName() returns the name of the persister
java.lang.String	getOperation() returns the string of the operation
int	getStatus() returns the status of the persister
int	getXAMode() returns the transaction mode of the persister
protected boolean	isStopped(XQueue xq)
protected boolean	keepRunning(XQueue xq)
abstract void	persist(XQueue xq, int baseTime) gets all the JMS messages from the XQueue and delivers them to their destinations.
protected void	resetStatus(int current, int status)
void	setStatus(int status) sets the status of the persister

Methods inherited from class java.lang.Object

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

Field Detail

uri

protected java.lang.String uri

operation

protected java.lang.String operation

linkName

protected java.lang.String linkName

xaMode

protected int xaMode

capacity

protected int capacity

status

protected int status

repeatPeriod

protected int repeatPeriod

maxRetry

protected int maxRetry

tolerance

protected int tolerance

pauseTime

protected int pauseTime

standbyTime

protected int standbyTime

timeout

protected int timeout

displayMask

protected int displayMask

propertyName

protected java.lang.String[] propertyName

waitTime

protected long waitTime

partition

protected int[] partition

Constructor Detail

Persister

public Persister(java.util.Map props)

Method Detail

persist

public abstract 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

close

public abstract void close()

Description copied from interface: MessagePersister

closes all opened resources

Specified by:

close in interface MessagePersister

resetStatus

protected void resetStatus(int current,
                           int status)

keepRunning

protected boolean keepRunning(XQueue xq)

isStopped

protected boolean isStopped(XQueue xq)

getName

public java.lang.String getName()

Description copied from interface: MessagePersister

returns the name of the persister

Specified by:

getName in interface MessagePersister

getOperation

public java.lang.String getOperation()

Description copied from interface: MessagePersister

returns the string of the operation

Specified by:

getOperation in interface MessagePersister

getLinkName

public java.lang.String getLinkName()

Description copied from interface: MessagePersister

returns the name of the InLink

Specified by:

getLinkName in interface MessagePersister

getXAMode

public int getXAMode()

Description copied from interface: MessagePersister

returns the transaction mode of the persister

Specified by:

getXAMode in interface MessagePersister

getCapacity

public int getCapacity()

Description copied from interface: MessagePersister

returns the capacity of the InLink

Specified by:

getCapacity in interface MessagePersister

getStatus

public int getStatus()

Description copied from interface: MessagePersister

returns the status of the persister

Specified by:

getStatus in interface MessagePersister

setStatus

public void setStatus(int status)

Description copied from interface: MessagePersister

sets the status of the persister

Specified by:

setStatus in interface MessagePersister