void (WorkerThreadRequest newRequest) { final WorkerThreadRequest currentThreadRequest = getCurrentThreadRequest(); LOG.assertTrue(currentThreadRequest != null); myCurrentRequest = newRequest; if (LOG.isDebugEnabled()) { LOG.debug("Closing " + currentThreadRequest + " new request = " + newRequest); } currentThreadRequest.requestStop(); }