svn commit: r475303 - in /incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/mina: AcceptorTest.java WriterTest.java

[ritchiem]

Author: ritchiem
Date: Wed Nov 15 08:36:23 2006
New Revision: 475303

URL: http://svn.apache.org/viewvc?view=rev&rev=475303
Log:
QPID-92 fixed outstanding mina 1.1.0 build issues

Modified:
    
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/mina/AcceptorTest.java
    
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/mina/WriterTest.java

Modified: 
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/mina/AcceptorTest.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/mina/AcceptorTest.java?view=diff&rev=475303&r1=475302&r2=475303
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/mina/AcceptorTest.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/mina/AcceptorTest.java
 Wed Nov 15 08:36:23 2006
@@ -27,7 +27,6 @@
 import org.apache.mina.common.IoHandlerAdapter;
 import org.apache.mina.common.IoSession;
 import org.apache.mina.transport.socket.nio.SocketAcceptor;
-import org.apache.mina.transport.socket.nio.SocketAcceptorConfig;
 import org.apache.mina.transport.socket.nio.SocketSessionConfig;
 import org.junit.Test;
 import org.apache.qpid.pool.ReadWriteThreadModel;
@@ -76,17 +75,18 @@
     {
         IoAcceptor acceptor = null;
         acceptor = new SocketAcceptor();
-        
-        SocketAcceptorConfig config = (SocketAcceptorConfig) 
acceptor.getDefaultConfig();
-        SocketSessionConfig sc = (SocketSessionConfig) 
config.getSessionConfig();
+
+        SocketSessionConfig sc = (SocketSessionConfig) 
acceptor.getSessionConfig();
         sc.setTcpNoDelay(true);
         sc.setSendBufferSize(32768);
         sc.setReceiveBufferSize(32768);
 
-        config.setThreadModel(new ReadWriteThreadModel());
+        acceptor.setThreadModel(new ReadWriteThreadModel());
+
+        acceptor.setLocalAddress(new InetSocketAddress(PORT));
+        acceptor.setHandler(new TestHandler());
+        acceptor.bind();
 
-        acceptor.bind(new InetSocketAddress(PORT),
-                      new TestHandler());
         _logger.info("Bound on port " + PORT);
     }
 

Modified: 
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/mina/WriterTest.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/mina/WriterTest.java?view=diff&rev=475303&r1=475302&r2=475303
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/mina/WriterTest.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/mina/WriterTest.java
 Wed Nov 15 08:36:23 2006
@@ -24,7 +24,6 @@
 import org.apache.log4j.Logger;
 import org.apache.mina.common.*;
 import org.apache.mina.transport.socket.nio.SocketConnector;
-import org.apache.mina.transport.socket.nio.SocketConnectorConfig;
 import org.apache.mina.transport.socket.nio.SocketSessionConfig;
 import org.junit.Test;
 
@@ -181,16 +180,15 @@
 
         ioConnector = new SocketConnector();
         
-        SocketConnectorConfig cfg = (SocketConnectorConfig) 
ioConnector.getDefaultConfig();
-        cfg.setThreadModel(ThreadModel.MANUAL);
-        SocketSessionConfig scfg = (SocketSessionConfig) 
cfg.getSessionConfig();
+        SocketSessionConfig scfg = (SocketSessionConfig) 
ioConnector.getSessionConfig();
         scfg.setTcpNoDelay(true);
         scfg.setSendBufferSize(32768);
         scfg.setReceiveBufferSize(32768);
 
         final InetSocketAddress address = new InetSocketAddress("localhost", 
AcceptorTest.PORT);
         _logger.info("Attempting connection to " + address);
-        ConnectFuture future = ioConnector.connect(address, new 
WriterHandler());
+        ioConnector.setHandler(new WriterHandler());
+        ConnectFuture future = ioConnector.connect(address);
         // wait for connection to complete
         future.join();
         _logger.info("Connection completed");