msgs.notify();
msgs.notifyAll();
    public void stop() {	Entry entry;	// i. If retransmitter is owned, stop it else cancel all tasks	// ii. Clear all pending msgs and notify anyone waiting	synchronized(msgs) {	    if (retransmitter_owned) {		try {		    retransmitter.stop();		} catch(InterruptedException ex) {		    if(log.isErrorEnabled()) log.error(_toString(ex));		}	    } else {		for (Enumeration e = msgs.elements(); e.hasMoreElements();) {		    entry = (Entry)e.nextElement();		    entry.cancel();		}	    }	    msgs.clear();	    // wake up waitUntilAllAcksReceived() method	    msgs.notify();	}    }