if(down_thread) { if(down_handler == null) { down_handler=new DownHandler(down_queue, this, observer); if(down_thread_prio >= 0) { try { down_handler.setPriority(down_thread_prio); } catch(Throwable t) { if(log.isErrorEnabled()) log.error("priority " + down_thread_prio + " could not be set for thread: " + Util.getStackTrace(t)); } } down_handler.start(); } } }
if (down_thread) { if (down_handler == null) { down_handler = new DownHandler(down_queue, this, observer); if (down_thread_prio >= 0) { try { down_handler.setPriority(down_thread_prio); } catch (Throwable t) { if (log.isErrorEnabled()) { log.error("priority " + down_thread_prio + " could not be set for thread: " + Util.getStackTrace(t)); } } } down_handler.start(); } } }
    public void startDownHandler() {        if(down_thread) {            if(down_handler == null) {                down_handler=new DownHandler(down_queue, this, observer);                if(down_thread_prio >= 0) {                    try {                        down_handler.setPriority(down_thread_prio);                    }                    catch(Throwable t) {                        if(log.isErrorEnabled()) log.error("priority " + down_thread_prio +                                    " could not be set for thread: " + Util.getStackTrace(t));                    }                }                down_handler.start();            }        }    }