running=false;
is_it_running=false; try { tmp.join(MAX_JOIN_TIMEOUT); } catch(InterruptedException e) { } if(tmp.isAlive()) { if(log.isWarnEnabled()) log.warn("sender thread was interrupted, but is still alive: " + tmp); }
           void stop() {               if(senderThread != null) {                   if(send_queue != null)                       send_queue.close(false);                   Thread tmp=senderThread;                   senderThread=null;                   tmp.interrupt();                   running=false;               }           }