[jboss-remoting-commits] JBoss Remoting SVN: r4606 - in remoting3/trunk: protocol/basic/src/test/java/org/jboss/remoting/protocol/basic and 1 other directory.
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!"));
-
+
}
}