[jboss-remoting-commits] JBoss Remoting SVN: r4606 - in remoting3/trunk: protocol/basic/src/test/java/org/jboss/remoting/protocol/basic and 1 other directory.

[jboss-remoting-commits at lists.jboss.org]

Author: david.lloyd at 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!"));
-        
+
     }
 }