com.ibm.di.queue
Class MemBufferThread

java.lang.Object
  java.lang.Thread
      com.ibm.di.queue.MemBufferThread

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

MemBufferLoaderThread, MemBufferStoreThread

public abstract class MemBufferThread
extends Thread

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

static ActionListener	actionListener
protected static boolean	bDirty
protected static PESConnector	connect
protected MemQ	memQ
protected int	size

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

MemBufferThread(MemQ q, int size)
constructor

Method Summary

static void	addActionListener(ActionListener l)
void	fireListener(ActionEvent e)
void	Initialize(String sDBName, String jdbcLogin, String jdbcPassword, String sTblName) Initializes the system store paramemters
boolean	isStoreEmpty()
static void	removeActionListener(ActionListener l)
void	terminate() terminates the system store operation

Methods inherited from class java.lang.Thread

activeCount, checkAccess, 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, run, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

memQ

protected MemQ memQ

size

protected int size

connect

protected static PESConnector connect

bDirty

protected static boolean bDirty

actionListener

public static ActionListener actionListener

Constructor Detail

MemBufferThread

public MemBufferThread(MemQ q,
                       int size)

constructor

Parameters:

q - if store thread then it is the chunk if loader thread then the main memq

size - threshold if loading pagesize if storing

Method Detail

addActionListener

public static void addActionListener(ActionListener l)

removeActionListener

public static void removeActionListener(ActionListener l)

fireListener

public void fireListener(ActionEvent e)

Initialize

public void Initialize(String sDBName,
                       String jdbcLogin,
                       String jdbcPassword,
                       String sTblName)
                throws Exception

Initializes the system store paramemters

Parameters:

sDBName - system store database name

jdbcLogin - username to connect to the db

jdbcPassword - password to connect to the db

sTblName - table name

Throws:

Exception - if system store is not initialized properly

terminate

public void terminate()

terminates the system store operation

isStoreEmpty

public boolean isStoreEmpty()