org.xmlBlaster.test.classtest.queue
Class QueueThread

java.lang.Object
  java.lang.Thread
      org.xmlBlaster.test.classtest.queue.QueueThread

All Implemented Interfaces:

java.lang.Runnable

class QueueThread

extends java.lang.Thread

Field Summary

static int	counter
private java.util.ArrayList	entryList
private Global	glob
private static java.util.logging.Logger	log
private static java.lang.String	ME
private java.lang.String	name
private I_Queue	queue
private int	sizeOfMsg
private int	sweeps

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

QueueThread(Global glob, java.lang.String name, I_Queue queue, java.util.logging.Logger log, int sweeps, int sizeOfMsg)

Method Summary

void	run()
protected void	runPeekAllRemoveOneByOne()
protected void	runPut()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, 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

ME

private static final java.lang.String ME

See Also:

Constant Field Values

queue

private I_Queue queue

sweeps

private int sweeps

log

private static java.util.logging.Logger log

name

private java.lang.String name

sizeOfMsg

private int sizeOfMsg

glob

private Global glob

counter

public static int counter

entryList

private java.util.ArrayList entryList

Constructor Detail

QueueThread

public QueueThread(Global glob,
                   java.lang.String name,
                   I_Queue queue,
                   java.util.logging.Logger log,
                   int sweeps,
                   int sizeOfMsg)
            throws XmlBlasterException,
                   java.sql.SQLException

Method Detail

runPut

protected void runPut()

runPeekAllRemoveOneByOne

protected void runPeekAllRemoveOneByOne()

run

public void run()