Author: david.lloyd(a)jboss.com Date: 2008-10-21 01:35:10 -0400 (Tue, 21 Oct 2008) New Revision: 4606 Modified: remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientImpl.java remoting3/trunk/protocol/basic/src/test/java/org/jboss/remoting/protocol/basic/BasicTestCase.java Log: Minor cleanups Modified: remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientImpl.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientImpl.java 2008-10-21 05:32:25 UTC (rev 4605) +++ remoting3/trunk/core/src/main/java/org/jboss/remoting/core/ClientImpl.java 2008-10-21 05:35:10 UTC (rev 4606) @@ -30,12 +30,8 @@ import org.jboss.remoting.spi.remote.RemoteRequestContext; import org.jboss.remoting.spi.remote.Handle; import org.jboss.xnio.IoFuture; -import org.jboss.marshalling.Externalizer; -import org.jboss.marshalling.Creator; import java.util.concurrent.Executor; import java.io.IOException; -import java.io.ObjectOutput; -import java.io.ObjectInput; /** * Modified: remoting3/trunk/protocol/basic/src/test/java/org/jboss/remoting/protocol/basic/BasicTestCase.java =================================================================== --- remoting3/trunk/protocol/basic/src/test/java/org/jboss/remoting/protocol/basic/BasicTestCase.java 2008-10-21 05:32:25 UTC (rev 4605) +++ remoting3/trunk/protocol/basic/src/test/java/org/jboss/remoting/protocol/basic/BasicTestCase.java 2008-10-21 05:35:10 UTC (rev 4606) @@ -45,6 +45,7 @@ import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; import java.util.concurrent.LinkedBlockingQueue; +import java.util.concurrent.ExecutorService; import java.io.IOException; /** @@ -56,7 +57,7 @@ } public static void testConnect() throws Throwable { - Executor executor = new ThreadPoolExecutor(10, 10, 0L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>()); + ExecutorService executor = new ThreadPoolExecutor(10, 10, 0L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>()); Xnio xnio = NioXnio.create(executor, 2, 2, 2); final BasicConfiguration configuration = new BasicConfiguration(); configuration.setExecutor(executor); @@ -103,6 +104,6 @@ final Handle<RequestHandler> clientHandlerHandle = BasicProtocol.createClient(futureChannel.get(), configuration); final Client<Object,Object> client = endpoint.createClient(clientHandlerHandle.getResource()); System.out.println("Reply is:" + client.invoke("GORBA!")); - + } }