xyz.cofe.sql

Class MessageReader

java.lang.Object

java.lang.Thread

xyz.cofe.sql.MessageReader

All Implemented Interfaces:

Runnable

public class MessageReader
extends Thread

Чтение сообщений из Statement warnings

Author:

Kamnev Georgiy

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected Reciver<SQLWarning>	consumer
protected Set<SQLWarning>	readed
protected long	sleep
protected Level	sqlWarnLevel
protected long	startLag
protected Statement	statement
protected Object	sync
protected long	waitForOpen
protected long	waitForOpenTimeout

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
MessageReader(Statement st, Reciver<SQLWarning> consumer)
MessageReader(Statement st, Reciver<SQLWarning> consumer, int sleep)

Method Summary

Modifier and Type	Method and Description
Reciver<SQLWarning>	getConsumer()
long	getSleep()
Level	getSqlWarnLevel()
Statement	getStatement()
Object	getSync()
void	releaseStatement()
void	run()
void	setConsumer(Reciver<SQLWarning> ncons)
void	setSleep(long sleep)
void	setSqlWarnLevel(Level sqlWarnLevel)
void	setStatement(Statement st)
void	terminate(long timeout, long sleep) Остановка выполнения.

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

sync

protected final Object sync

statement

protected Statement statement

consumer

protected Reciver<SQLWarning> consumer

readed

protected final Set<SQLWarning> readed

sqlWarnLevel

protected Level sqlWarnLevel

sleep

protected long sleep

startLag

protected long startLag

waitForOpenTimeout

protected long waitForOpenTimeout

waitForOpen

protected long waitForOpen

Constructor Detail

MessageReader

public MessageReader(Statement st,
                     Reciver<SQLWarning> consumer,
                     int sleep)

MessageReader

public MessageReader(Statement st,
                     Reciver<SQLWarning> consumer)

Method Detail

getSync

public Object getSync()

getStatement

public Statement getStatement()

setStatement

public void setStatement(Statement st)

releaseStatement

public void releaseStatement()

getConsumer

public Reciver<SQLWarning> getConsumer()

setConsumer

public void setConsumer(Reciver<SQLWarning> ncons)

getSqlWarnLevel

public Level getSqlWarnLevel()

setSqlWarnLevel

public void setSqlWarnLevel(Level sqlWarnLevel)

getSleep

public long getSleep()

setSleep

public void setSleep(long sleep)

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

terminate

public void terminate(long timeout,
                      long sleep)

Остановка выполнения.

Нельзя вызывать только в самом же треде.

Parameters:

timeout - макс. время (мс) за которое должна произойти остановка

sleep - время (мс) паузы, при значении < 0 - передает управление другому потоку Thread.yield()