Event evt; while(!mq.closed()) { try { evt=(Event)mq.remove(); if(evt == null) { if(log.isWarnEnabled()) log.warn("removed null event"); continue; }
Event evt; while (!mq.closed()) { try { handler.blockUntilDownReady(); evt = (Event) mq.remove(); if (evt == null) { if (log.isWarnEnabled()) { log.warn("removed null event"); } continue; }
    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.down(evt, mq.size()) == false) {  // false means discard event                        continue;                    }                }                int type=evt.getType();                if(type == Event.ACK || type == Event.START || type == Event.STOP) {                    if(handler.handleSpecialDownEvent(evt) == false)                        continue;                }                handler.down(evt);                evt=null;            }            catch(QueueClosedException queue_closed) {                break;            }            catch(Throwable e) {                if(log.isWarnEnabled()) log.warn(getName() + " exception is " + e);                e.printStackTrace();            }        }    }