com.konakartadmin.bl

Class AdminConfigCacheUpdater

java.lang.Object

java.lang.Thread

com.konakartadmin.bl.AdminConfigCacheUpdater

All Implemented Interfaces:

java.lang.Runnable

public class AdminConfigCacheUpdater
extends java.lang.Thread

Thread which runs forever. At a regular interval it checks to see whether the cache of configuration variables needs updating and updates it if required.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
private AdminConfigurationMgrIf	adminConfMgr AdminConfigurationMgr
private java.util.HashMap<java.lang.String,AdminConfigurationMgrIf>	adminConfMgrMap Keep the AdminConfigMgr instances in a map
private static long	DEFAULT_SLEEP_MILLIS Default sleep time in millis (30 secs)
private KKAdminIf	eng Engine Instance that started the thread
private java.util.HashMap<java.lang.String,java.util.Date>	lastModifiedMap Last time the config variable was modified.
private org.apache.commons.logging.Log	log The Log instance for this class.
private boolean	loop Variable to decide whether to keep looping
private long	sleepMillis

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
AdminConfigCacheUpdater(KKAdminIf eng) Constructor

Method Summary

Modifier and Type	Method and Description
private AdminConfigurationMgrIf	addConfigMgrToMap(java.lang.String storeId) Add an engine to the engine map
private KKConfiguration[]	getConfigsInMultiStoreSharedDBMode() An array of KKConfiguration objects is returned; one for each store.
void	run() This thread runs forever.
private void	setCheckInterval() Set the interval for checking the configuration flag.
void	stopLooping() Stop the current thread from looping
private void	updateConfigs() Reads a config variable for all stores and decides whether or not to do the update based on whether the config variable was modified since last time it was read.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

log

private org.apache.commons.logging.Log log

The Log instance for this class.

DEFAULT_SLEEP_MILLIS

private static final long DEFAULT_SLEEP_MILLIS

Default sleep time in millis (30 secs)

See Also:

Constant Field Values

sleepMillis

private long sleepMillis

lastModifiedMap

private java.util.HashMap<java.lang.String,java.util.Date> lastModifiedMap

Last time the config variable was modified. The key for the map is the store id

adminConfMgrMap

private java.util.HashMap<java.lang.String,AdminConfigurationMgrIf> adminConfMgrMap

Keep the AdminConfigMgr instances in a map

loop

private boolean loop

Variable to decide whether to keep looping

eng

private KKAdminIf eng

Engine Instance that started the thread

adminConfMgr

private AdminConfigurationMgrIf adminConfMgr

AdminConfigurationMgr

Constructor Detail

AdminConfigCacheUpdater

public AdminConfigCacheUpdater(KKAdminIf eng)
                        throws java.lang.Exception

Constructor

Parameters:

eng - The engine that started the thread

Throws:

java.lang.Exception - an unexpected exception

Method Detail

setCheckInterval

private void setCheckInterval()
                       throws com.konakart.app.KKException,
                              KKAdminException

Set the interval for checking the configuration flag. In a multi-store scenario the config variable containing the interval will be read from the store set for the engine that started this thread.

Throws:

com.konakart.app.KKException - an unexpected KKException exception

KKAdminException - an unexpected KKAdminException exception

stopLooping

public void stopLooping()

Stop the current thread from looping

run

public void run()

This thread runs forever. At a regular interval it checks to see whether the cache of configuration variables needs updating and updates it if required. Under certain conditions this thread continues even when the main application has been stopped.

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

updateConfigs

private void updateConfigs()
                    throws java.lang.Exception

Reads a config variable for all stores and decides whether or not to do the update based on whether the config variable was modified since last time it was read.

Throws:

java.lang.Exception - an unexpected exception

addConfigMgrToMap

private AdminConfigurationMgrIf addConfigMgrToMap(java.lang.String storeId)
                                           throws java.lang.Exception

Add an engine to the engine map

Parameters:

storeId - the storeId

Returns:

the AdminConfigurationMgr instance that was also added to the map

Throws:

java.lang.Exception - an unexpected exception

getConfigsInMultiStoreSharedDBMode

private KKConfiguration[] getConfigsInMultiStoreSharedDBMode()
                                                      throws org.apache.torque.TorqueException,
                                                             com.workingdogs.village.DataSetException,
                                                             com.konakart.app.KKException

An array of KKConfiguration objects is returned; one for each store. If a config with key ADMIN_CONFIG_CACHE_CHECK_FLAG doesn't exist for a store, then that store is never refreshed.

Returns:

Return an array of KKConfiguration objects

Throws:

org.apache.torque.TorqueException - an unexpected exception in Torque (the database layer)

com.workingdogs.village.DataSetException - an unexpected exception due to data in Torque (the database layer)

com.konakart.app.KKException - an unexpected KKException exception