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() Удаление ссылки на statement
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)

Конструктор

Parameters:

st - SQL Statement из которого будут прочитываться сообщения

consumer - Приемник сообщений

sleep - задержка между приемами сообщений

MessageReader

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

Конструктор

Parameters:

st - SQL Statement из которого будут прочитываться сообщения

consumer - Приемник сообщений

Method Detail

getSync

public Object getSync()

getStatement

public Statement getStatement()

setStatement

public void setStatement(Statement st)

releaseStatement

public void releaseStatement()

Удаление ссылки на statement

getConsumer

public Reciver<SQLWarning> getConsumer()

setConsumer

public void setConsumer(Reciver<SQLWarning> ncons)

getSqlWarnLevel

public Level getSqlWarnLevel()

Указывает уровень логирования сообщений

Returns:

уровень логирования - по умолчанию FINE

setSqlWarnLevel

public void setSqlWarnLevel(Level sqlWarnLevel)

Указывает уровень логирования сообщений

Parameters:

sqlWarnLevel - уровень логирования - по умолчанию FINE

getSleep

public long getSleep()

Указывает задержку для ожидания поступления нового сообщения

Returns:

задержка в мс

setSleep

public void setSleep(long sleep)

Указывает задержку для ожидания поступления нового сообщения

Parameters:

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()