if(up_thread) { if(up_handler == null) { up_handler=new UpHandler(up_queue, this, observer); if(up_thread_prio >= 0) { try { up_handler.setPriority(up_thread_prio); } catch(Throwable t) { if(log.isErrorEnabled()) log.error("priority " + up_thread_prio + " could not be set for thread: " + Util.getStackTrace(t)); } } up_handler.start(); } } }
if (up_thread) { if (up_handler == null) { up_handler = new UpHandler(up_queue, this, observer); if (up_thread_prio >= 0) { try { up_handler.setPriority(up_thread_prio); } catch (Throwable t) { if (log.isErrorEnabled()) { log.error("priority " + up_thread_prio + " could not be set for thread: " + Util.getStackTrace(t)); } } } up_handler.start(); } } }
    public void startUpHandler() {        if(up_thread) {            if(up_handler == null) {                up_handler=new UpHandler(up_queue, this, observer);                if(up_thread_prio >= 0) {                    try {                        up_handler.setPriority(up_thread_prio);                    }                    catch(Throwable t) {                        if(log.isErrorEnabled()) log.error("priority " + up_thread_prio +                                    " could not be set for thread: " + Util.getStackTrace(t));                    }                }                up_handler.start();            }        }    }