if(observer != null) { if(observer.up(evt, mq.size()) == false) { return; } } handler.up(evt); evt=null; } catch(QueueClosedException queue_closed) { break; } catch(Throwable e) { if(log.isWarnEnabled()) log.warn(getName() + " exception: " + e); e.printStackTrace(); } } }
if (observer != null) { if (observer.up(evt, mq.size()) == false) { return; } } handler.up(evt); evt = null; } catch (QueueClosedException queue_closed) { break; } catch (Throwable e) { if (log.isWarnEnabled()) { log.warn(getName() + " exception: " + e); } e.printStackTrace(); } } }
    public void run() {        Event evt;        while(!mq.closed()) {            try {                evt=(Event)mq.remove();                if(evt == null) {                    if(log.isWarnEnabled()) log.warn("removed null event");                    continue;                }                if(observer != null) {                          // call debugger hook (if installed)                    if(observer.up(evt, mq.size()) == false) {  // false means discard event                        return;                    }                }                handler.up(evt);                evt=null;            }            catch(QueueClosedException queue_closed) {                break;            }            catch(Throwable e) {                if(log.isWarnEnabled()) log.warn(getName() + " exception: " + e);                e.printStackTrace();            }        }    }