while(sender != null && sender.equals(Thread.currentThread())) {
while(senderThread != null && senderThread.equals(Thread.currentThread())) {
            public void run() {                Message msg;                while(sender != null && sender.equals(Thread.currentThread())) {                    try {                        msg=(Message)send_queue.poll(POLL_TIMEOUT);                        if(msg == null)                            break;                        _send(msg);                    }                    catch(InterruptedException e) {                        break;                    }                }                running=false;                if(log.isTraceEnabled())                    log.trace("ConnectionTable.Connection.Sender thread terminated");            }