com.konakartadmin.bl

Class ERPQueueReader

java.lang.Object

java.lang.Thread

com.konakartadmin.bl.ERPQueueReader

All Implemented Interfaces:

java.lang.Runnable

public class ERPQueueReader
extends java.lang.Thread

Thread which runs forever. At a regular interval it reads the MQ Queue

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	ERPQueueReader.KKEngines Class used to transport the admin and App engines
private class	ERPQueueReader.MsgCount Class to keep track of the message count

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 java.lang.String	defaultStoreId Default storeId - comes from the setting in the Incoming Message Processor servlet definition in the web.xml
private AdminEngineCacheMgrIf	engMgr KK Engine Mgr to manage engines for different stores
private org.apache.commons.logging.Log	log The Log instance for this class.
private java.lang.String	logBasePathKO Base path for the log for messages that have failed
private java.lang.String	logBasePathOK Base path for the log for messages that have passed
private boolean	loop Variable to decide whether to keep looping
private long	mqInitialPauseMillis Initial Sleep time in millis - this is to allow the MQ Service to start in another webapp
private com.konakart.mqif.MqMgrIf	mqMgr MQMgr to read the queue
private com.konakart.appif.MqOptionsIf	mqOptions MQ Options object for reading the queue
private long	mqReadFrequencyMillis Sleep time in millis
private AdminServletMgrIf	servletMgr Manager started by the servlet used to set off this thread

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
ERPQueueReader()

Method Summary

Modifier and Type	Method and Description
java.lang.String	getDefaultStoreId()
AdminEngineCacheMgrIf	getEngMgr()
private ERPQueueReader.KKEngines	getKKEngines(java.lang.String storeId) Utility method to return Admin and App engines from a cache
java.lang.String	getLogBasePathKO()
java.lang.String	getLogBasePathOK()
private java.lang.String	getLogName(boolean passed) Returns the name of a log for a message
long	getMqInitialPauseMillis()
com.konakart.mqif.MqMgrIf	getMqMgr()
com.konakart.appif.MqOptionsIf	getMqOptions()
long	getMqReadFrequencyMillis()
AdminServletMgrIf	getServletMgr()
private void	msgReturnlog(boolean ret, AdminImportMgrIf mgr, java.lang.StringBuffer logSB, com.konakart.erp.jaxb.IOMsgBase msg, ERPQueueReader.MsgCount msgCount) Utility method called after the return of a message processing call
private void	processMsg(com.konakart.appif.MqResponseIf mqresp) Method used to process the messages read from MQ
void	run() This thread runs forever.
private void	sendExceptionEmail(ERPQueueReader.KKEngines engines, java.lang.String logName) Send an email with the log as an attachment
void	setDefaultStoreId(java.lang.String defaultStoreId)
void	setEngMgr(AdminEngineCacheMgrIf engMgr)
void	setLogBasePathKO(java.lang.String logBasePathKO)
void	setLogBasePathOK(java.lang.String logBasePathOK)
void	setMqInitialPauseMillis(long mqInitialPauseMillis)
void	setMqMgr(com.konakart.mqif.MqMgrIf mqMgr)
void	setMqOptions(com.konakart.appif.MqOptionsIf mqOptions)
void	setMqReadFrequencyMillis(long mqReadFrequencyMillis)
void	setServletMgr(AdminServletMgrIf servletMgr)
void	stopLooping() Stop the current thread from looping

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.

mqReadFrequencyMillis

private long mqReadFrequencyMillis

Sleep time in millis

mqInitialPauseMillis

private long mqInitialPauseMillis

Initial Sleep time in millis - this is to allow the MQ Service to start in another webapp

mqMgr

private com.konakart.mqif.MqMgrIf mqMgr

MQMgr to read the queue

engMgr

private AdminEngineCacheMgrIf engMgr

KK Engine Mgr to manage engines for different stores

servletMgr

private AdminServletMgrIf servletMgr

Manager started by the servlet used to set off this thread

mqOptions

private com.konakart.appif.MqOptionsIf mqOptions

MQ Options object for reading the queue

logBasePathOK

private java.lang.String logBasePathOK

Base path for the log for messages that have passed

logBasePathKO

private java.lang.String logBasePathKO

Base path for the log for messages that have failed

loop

private boolean loop

Variable to decide whether to keep looping

defaultStoreId

private java.lang.String defaultStoreId

Default storeId - comes from the setting in the Incoming Message Processor servlet definition in the web.xml

Constructor Detail

ERPQueueReader

public ERPQueueReader()

Method Detail

stopLooping

public void stopLooping()

Stop the current thread from looping

run

public void run()

This thread runs forever. At a regular interval it reads the MQ queue

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

processMsg

private void processMsg(com.konakart.appif.MqResponseIf mqresp)
                 throws java.io.IOException

Method used to process the messages read from MQ

Parameters:

mqresp - the mqresp

Throws:

java.io.IOException - an unexpected IOException exception

sendExceptionEmail

private void sendExceptionEmail(ERPQueueReader.KKEngines engines,
                                java.lang.String logName)
                         throws java.lang.Exception

Send an email with the log as an attachment

Parameters:

engines - the engines

logName - the logName

Throws:

java.lang.Exception - an unexpected exception

msgReturnlog

private void msgReturnlog(boolean ret,
                          AdminImportMgrIf mgr,
                          java.lang.StringBuffer logSB,
                          com.konakart.erp.jaxb.IOMsgBase msg,
                          ERPQueueReader.MsgCount msgCount)
                   throws java.io.IOException,
                          com.konakart.app.KKException

Utility method called after the return of a message processing call

Parameters:

ret - the ret

mgr - the mgr

logSB - the logSB

msg - the msg

msgCount - the msgCount

Throws:

java.io.IOException - an unexpected IOException exception

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

getKKEngines

private ERPQueueReader.KKEngines getKKEngines(java.lang.String storeId)
                                       throws java.lang.Exception

Utility method to return Admin and App engines from a cache

Parameters:

storeId - the storeId

Returns:

Returns an object containing the admin and app engines

Throws:

java.lang.Exception - an unexpected exception

getLogName

private java.lang.String getLogName(boolean passed)

Returns the name of a log for a message

Parameters:

passed - the passed

Returns:

Returns the name of a log for a message

getMqMgr

public com.konakart.mqif.MqMgrIf getMqMgr()

Returns:

the mqMgr

setMqMgr

public void setMqMgr(com.konakart.mqif.MqMgrIf mqMgr)

Parameters:

mqMgr - the mqMgr to set

getEngMgr

public AdminEngineCacheMgrIf getEngMgr()

Returns:

the engMgr

setEngMgr

public void setEngMgr(AdminEngineCacheMgrIf engMgr)

Parameters:

engMgr - the engMgr to set

getMqOptions

public com.konakart.appif.MqOptionsIf getMqOptions()

Returns:

the mqOptions

setMqOptions

public void setMqOptions(com.konakart.appif.MqOptionsIf mqOptions)

Parameters:

mqOptions - the mqOptions to set

getLogBasePathOK

public java.lang.String getLogBasePathOK()

Returns:

the logBasePathOK

setLogBasePathOK

public void setLogBasePathOK(java.lang.String logBasePathOK)

Parameters:

logBasePathOK - the logBasePathOK to set

getLogBasePathKO

public java.lang.String getLogBasePathKO()

Returns:

the logBasePathKO

setLogBasePathKO

public void setLogBasePathKO(java.lang.String logBasePathKO)

Parameters:

logBasePathKO - the logBasePathKO to set

getMqReadFrequencyMillis

public long getMqReadFrequencyMillis()

Returns:

the mqReadFrequencyMillis

setMqReadFrequencyMillis

public void setMqReadFrequencyMillis(long mqReadFrequencyMillis)

Parameters:

mqReadFrequencyMillis - the mqReadFrequencyMillis to set

getServletMgr

public AdminServletMgrIf getServletMgr()

Returns:

the servletMgr

setServletMgr

public void setServletMgr(AdminServletMgrIf servletMgr)

Parameters:

servletMgr - the servletMgr to set

getDefaultStoreId

public java.lang.String getDefaultStoreId()

Returns:

the defaultStoreId

setDefaultStoreId

public void setDefaultStoreId(java.lang.String defaultStoreId)

Parameters:

defaultStoreId - the defaultStoreId to set

getMqInitialPauseMillis

public long getMqInitialPauseMillis()

Returns:

the mqInitialPauseMillis

setMqInitialPauseMillis

public void setMqInitialPauseMillis(long mqInitialPauseMillis)

Parameters:

mqInitialPauseMillis - the mqInitialPauseMillis to set