Author: ron.sigal(a)jboss.com Date: 2010-11-11 22:34:38 -0500 (Thu, 11 Nov 2010) New Revision: 6131 Modified: remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/InboundRequestTask.java Log: JBREM-1257: The appropriate InboundClient is retrieved by RemoteMessageHandler instead of in a separate thread running InboundRequestTask. Modified: remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/InboundRequestTask.java =================================================================== --- remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/InboundRequestTask.java 2010-11-12 03:29:58 UTC (rev 6130) +++ remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/InboundRequestTask.java 2010-11-12 03:34:38 UTC (rev 6131) @@ -35,17 +35,17 @@ final class InboundRequestTask implements Runnable { private final InboundRequest inboundRequest; + private final InboundClient inboundClient; private final int rid; - private final int cid; private RemoteConnectionHandler remoteConnectionHandler; private static final Logger log = Loggers.main; - InboundRequestTask(final RemoteConnectionHandler remoteConnectionHandler, final InboundRequest inboundRequest, final int rid, final int cid) { + InboundRequestTask(final RemoteConnectionHandler remoteConnectionHandler, final InboundRequest inboundRequest, InboundClient inboundClient, final int rid) { this.remoteConnectionHandler = remoteConnectionHandler; this.inboundRequest = inboundRequest; + this.inboundClient = inboundClient; this.rid = rid; - this.cid = cid; } public void run() { @@ -55,11 +55,6 @@ inboundRequest.setReplyHandler(replyHandler = new OutboundReplyHandler(inboundRequest, rid)); } final RemoteConnectionHandler connectionHandler = remoteConnectionHandler; - final IntKeyMap<InboundClient> inboundClients = connectionHandler.getInboundClients(); - final InboundClient inboundClient; - synchronized (inboundClients) { - inboundClient = inboundClients.get(cid); - } final ClassLoader requestClassLoader = inboundClient.getHandler().getClassLoader(); final Object request; try {