Author: ron.sigal(a)jboss.com
Date: 2010-09-07 15:56:10 -0400 (Tue, 07 Sep 2010)
New Revision: 6093
Modified:
remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test/RemotingLocalTestBase.java
remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test/RemotingTestBase.java
Log:
JBREM-1228: Moved a couple of methods from RemotingTestBase to RemotingLocalTestBase.
Modified:
remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test/RemotingLocalTestBase.java
===================================================================
---
remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test/RemotingLocalTestBase.java 2010-09-07
19:55:26 UTC (rev 6092)
+++
remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test/RemotingLocalTestBase.java 2010-09-07
19:56:10 UTC (rev 6093)
@@ -45,12 +45,9 @@
import org.jboss.remoting3.RequestListener;
import org.jboss.remoting3.Endpoint.ServiceBuilder;
import org.jboss.remoting3.spi.ProtocolServiceType;
-import
org.jboss.remoting3.test.ClientServerRemoteConfigurationTestCase.TestRequestListener;
import org.jboss.xnio.AcceptingServer;
-import org.jboss.xnio.IoFuture;
import org.jboss.xnio.OptionMap;
import org.jboss.xnio.Xnio;
-import org.jboss.xnio.IoFuture.Status;
import org.jboss.xnio.log.Logger;
/**
@@ -98,6 +95,14 @@
protected void addConnectionProvider(ServerPackage sp, int id) throws IOException {
}
+ protected OptionMap getConnectionOptionMap() {
+ return OptionMap.EMPTY;
+ }
+
+ protected String getRemotingScheme() {
+ return "local";
+ }
+
public static class ServerPackage {
public ThreadPoolExecutor executor;
public Endpoint endpoint;
Modified:
remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test/RemotingTestBase.java
===================================================================
---
remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test/RemotingTestBase.java 2010-09-07
19:55:26 UTC (rev 6092)
+++
remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test/RemotingTestBase.java 2010-09-07
19:56:10 UTC (rev 6093)
@@ -116,10 +116,6 @@
return new RemoteProtocolDescriptor();
}
- protected OptionMap getConnectionOptionMap() {
- return OptionMap.EMPTY;
- }
-
protected void createTcpServer(ServerPackage sp,
ChannelListener<ConnectedStreamChannel<InetSocketAddress>> listener) throws
IOException {
log.debug(this + " creating TcpServer");
TcpServer tcpServer = sp.xnio.createTcpServer(listener, OptionMap.EMPTY);
Show replies by date