com.aspc.DBObj.Internal

Class TransactionWindow

java.lang.Object

com.aspc.DBObj.Internal.TransactionWindow

public final class TransactionWindow
extends java.lang.Object

JMS fault tolerance

The system relies on getting the JMS message which notifies of records being changed in a timely manner. If the message is not received the system will have stale or old cache information.
IFRAME src="../../../../com/aspc/remote/jms/doc-files/known_ways_to_lose_messages.html" frameborder=0 width="100%" height="100%" scrolling="no"> known ways to lose messages

THREAD MODE: MULTI-THREADED

Since:

13 May 2009

Author:

Nigel Leck

Field Summary

Fields

Modifier and Type	Field and Description
static long	EXPECTED_SEND_TIME the expected maximum transmission time
static long	MAX_SEND_TIME the expected maximum transmission time
static java.lang.String	PROPERTY_TRANSACTION_EXPECTED_SEND_TIME the property to control the expected transmission time
static java.lang.String	PROPERTY_TRANSACTION_MAX_SEND_TIME the property to control the expected maximum transmission time
static java.lang.String	PROPERTY_TRANSACTION_WINDOW_MINUTES the property to control the number of minutes to track the processing the transactions
static int	TRANSACTION_WINDOW_MINUTES the number of minutes to track the processing the transactions

Constructor Summary

Constructors

Constructor and Description
TransactionWindow(VirtualDB layer) constructor

Method Summary

Modifier and Type	Method and Description
boolean	checkMissedTransaction(long transID, long transactionMS) have we missed this transaction.
long	getErrorCount() The number of errors
long	getMissedCount() The number of transactions missed.
void	processTransaction(long transID, long transactionMS) process the transaction.
void	receivedTransaction(long transID, long transactionMS) process the transaction.
void	scan() scan the layer.
boolean	shouldLoadTransaction(long transID, long transactionMS) we require this transaction to be loaded.

Methods inherited from class java.lang.Object

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

Field Detail

PROPERTY_TRANSACTION_EXPECTED_SEND_TIME

public static final java.lang.String PROPERTY_TRANSACTION_EXPECTED_SEND_TIME

the property to control the expected transmission time

See Also:

Constant Field Values

EXPECTED_SEND_TIME

public static final long EXPECTED_SEND_TIME

the expected maximum transmission time

PROPERTY_TRANSACTION_MAX_SEND_TIME

public static final java.lang.String PROPERTY_TRANSACTION_MAX_SEND_TIME

the property to control the expected maximum transmission time

See Also:

Constant Field Values

MAX_SEND_TIME

public static final long MAX_SEND_TIME

the expected maximum transmission time

PROPERTY_TRANSACTION_WINDOW_MINUTES

public static final java.lang.String PROPERTY_TRANSACTION_WINDOW_MINUTES

the property to control the number of minutes to track the processing the transactions

See Also:

Constant Field Values

TRANSACTION_WINDOW_MINUTES

public static final int TRANSACTION_WINDOW_MINUTES

the number of minutes to track the processing the transactions

Constructor Detail

TransactionWindow

public TransactionWindow(VirtualDB layer)

constructor

Parameters:

layer - the layer

Method Detail

getMissedCount

public long getMissedCount()

The number of transactions missed.

Returns:

the missed count.

getErrorCount

public long getErrorCount()

The number of errors

Returns:

the missed count.

scan

public void scan()

scan the layer.

checkMissedTransaction

public boolean checkMissedTransaction(long transID,
                                      long transactionMS)

have we missed this transaction.

Parameters:

transID - the transaction to check

transactionMS - the transaction time

Returns:

true if we KNOW we have missed this transaction

shouldLoadTransaction

public boolean shouldLoadTransaction(long transID,
                                     long transactionMS)

we require this transaction to be loaded.

Parameters:

transID - the transaction to check

transactionMS - the transaction time

Returns:

true if we KNOW we have to process this transaction

receivedTransaction

public void receivedTransaction(long transID,
                                long transactionMS)

process the transaction.

Parameters:

transID - the transaction to check

transactionMS - the transaction time

processTransaction

public void processTransaction(long transID,
                               long transactionMS)

process the transaction.

Parameters:

transID - the transaction to check

transactionMS - the transaction time