xmlBlaster 2.1.0 API

org.xmlBlaster.test.classtest.queue
Class QueueThread

java.lang.Object
  extended by java.lang.Thread
      extended by org.xmlBlaster.test.classtest.queue.QueueThread
All Implemented Interfaces:
java.lang.Runnable

 class QueueThread
extends java.lang.Thread


Nested Class Summary
 
Nested classes/interfaces inherited from class java.lang.Thread
java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler
 
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, 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
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
Throws:
XmlBlasterException
java.sql.SQLException
Method Detail

runPut

protected void runPut()

runPeekAllRemoveOneByOne

protected void runPeekAllRemoveOneByOne()

run

public void run()
Specified by:
run in interface java.lang.Runnable
Overrides:
run in class java.lang.Thread

xmlBlaster 2.1.0 API

Copyright © 1999-2011 The xmlBlaster.org contributers.