[jboss-remoting-commits] JBoss Remoting SVN: r6145 - remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test.

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

Author: ron.sigal at jboss.com
Date: 2010-11-13 11:26:02 -0500 (Sat, 13 Nov 2010)
New Revision: 6145

Modified:
   remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test/AbstractRemoteTestCase.java
Log:
JBREM-1256: Changed Xnio.getInstance() to Xnio.getInstance(xnioName).

Modified: remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test/AbstractRemoteTestCase.java
===================================================================
--- remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test/AbstractRemoteTestCase.java	2010-11-13 16:24:35 UTC (rev 6144)
+++ remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test/AbstractRemoteTestCase.java	2010-11-13 16:26:02 UTC (rev 6145)
@@ -52,14 +52,14 @@
         authenticationProvider.addUser("user", "endpoint", "password".toCharArray());
     }
 
-    protected Connection getConnection() throws Exception {
+    protected Connection getConnection(String xnioName) throws Exception {
         final NetworkServerProvider provider = endpoint.getConnectionProviderInterface(getScheme(), NetworkServerProvider.class);
         assertNotNull(provider, "No remote provider interface");
         final OptionMap serverOptions = OptionMap.builder()
                 .setSequence(Options.SASL_MECHANISMS, "EXTERNAL", "DIGEST-MD5")
                 .getMap();
         final ChannelListener<ConnectedStreamChannel<InetSocketAddress>> listener = provider.getServerListener(serverOptions, authenticationProvider);
-        final Xnio xnio = Xnio.getInstance();
+        final Xnio xnio = Xnio.getInstance(xnioName);
         final AcceptingServer<InetSocketAddress, ?, ?> server = getServer(listener, xnio);
         final IoFuture<? extends BoundChannel<InetSocketAddress>> future = server.bind(new InetSocketAddress(InetAddress.getByName("127.0.0.1"), 0));
         final InetSocketAddress localAddress = future.get().getLocalAddress();