365366367368369370371372373374375
} Runnable work = new Runnable() { public void run() { try { Msg result = dispatcher.sendRequest(to, data); source.sendResponse(result, data.requestId); } catch (Throwable e) { log.trace("Request failed.", e); } }
420421422423424425426427428429430
} finally { safeClose(c); } try { Msg result = (AsyncMsg) requestId.poll(Registry.REQUEST_TIMEOUT); if (log.isTraceEnabled()) log.trace("response data was corelated for request: " + requestId.getID()); if (result == null) throw new TransportException("Request time out."); return result;