org.qbroker.persister

Class MessageTerminator

java.lang.Object

org.qbroker.persister.Persister

org.qbroker.persister.MessageTerminator

All Implemented Interfaces:

MessagePersister

public class MessageTerminator
extends Persister

MessageTerminator is similar to MessageEvaluator. It also contains a bunch of rulesets for evaluating messages. But which rule to invoked is determined by the match process rather than the value of the given property. Besides modifying the messages, such as setting their return code, a ruleset may acknowledge messages according to their cell ids. So MessageTerminator is used to terminate message channels.

Author:

yannanlu@yahoo.com

Field Summary

Fields inherited from class org.qbroker.persister.Persister

capacity, 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
MessageTerminator(java.util.Map props)

Method Summary

Modifier and Type	Method and Description
void	close() closes all opened resources
protected void	finalize()
int	getNumberOfRules()
java.lang.String	getRuleName(int i)
protected java.util.Map<java.lang.String,java.lang.Object>	initRuleset(long tm, java.util.Map ph, long[] ruleInfo) It initializes a new ruleset with the ruleInfo and returns the rule upon success.
void	persist(XQueue xq, int baseTime) gets all the JMS messages from the XQueue and delivers them to their destinations.
void	terminate(XQueue in) It picks up a message from input queue and evaluates its content to decide what return code to set.

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

MessageTerminator

public MessageTerminator(java.util.Map props)

Method Detail

initRuleset

protected java.util.Map<java.lang.String,java.lang.Object> initRuleset(long tm,
                                                                       java.util.Map ph,
                                                                       long[] ruleInfo)

It initializes a new ruleset with the ruleInfo and returns the rule upon success. Otherwise, it throws an exception or returns null.

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

terminate

public void terminate(XQueue in)

It picks up a message from input queue and evaluates its content to decide what return code to set. The evaluation may modify the content.

getRuleName

public java.lang.String getRuleName(int i)

getNumberOfRules

public int getNumberOfRules()

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