Author: ron.sigal(a)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();
Show replies by date