1 package org.sapia.ubik.rmi.server.transport.nio.tcp; 2 3 import java.io.IOException ; 4 import java.net.Socket ; 5 6 import org.sapia.ubik.net.Connection; 7 import org.sapia.ubik.net.SocketConnectionFactory; 8 9 26 public class NioRmiConnectionFactory extends SocketConnectionFactory { 27 28 private int _bufsize; 29 32 public NioRmiConnectionFactory(int bufsize) { 33 _bufsize = bufsize; 34 } 35 36 39 public Connection newConnection(Socket sock) throws IOException { 40 NioTcpRmiClientConnection conn = new NioTcpRmiClientConnection(sock, _bufsize); 41 42 return conn; 43 } 44 45 48 public Connection newConnection(String host, int port) throws IOException { 49 NioTcpRmiClientConnection conn = new NioTcpRmiClientConnection(new Socket ( 50 host, port), _bufsize); 51 52 return conn; 53 } 54 } 55 | Popular Tags |