[xSocket-develop] Beginner's problem with simple multiplexed server program

[Sharath <re...@ya...>]

Hi,

i thought of making a start with xsocket to developing a scalable nio server.

Based on the tutorial on the xsocket web site, I have written the following 
code: 2 classes, one is the main startup class, the other a pipeline handler:

public class ServerSocketMain {
   
    static private Logger logger = null;
    static private LoggingService loggingService = null;
    static private int socketPortNo;
   
    // Buffer size, in bytes, for I/O operations over the socket
    static private int buffer_size = 0;
   
   
    /**
     * Private constructor.
     */
    private ServerSocketMain () {
        logger = Logger.getLogger(this.getClass());
        loggingService = new LoggingService();
    }

    /**
     * main(): for starting the program
     *
     * @param args
     */
    /**
     * @param args
     */
    public static void main(String[] args) {

        ServerSocketMain multiConnServerSocket = new ServerSocketMain ();
       
        multiConnServerSocket.initializeSocketParams();
       
        try {
            multiConnServerSocket.setupSocketConnOperations();
        }
        catch (MarisCommsException e) {
            logger.fatal("MAYDAY MAYDAY: Cannot listen for client requests. 
Program terminated!");
        }
       
    }
   
    /**
     * Socket specific initializations performed here e.g. port number.
     */
    private void initializeSocketParams() {
       
        ResourceBundle serverSocketResources = 
ResourceBundle.getBundle("my.app.ServerSocket", Locale.US);
        String socketPortNoStr = (String) serverSocketResources 
.getObject("SOCKET_PORT_NO");
        socketPortNo = (new Integer(socketPortNoStr)).intValue();
        loggingService.debug("PORT NO = " + socketPortNo);
       
        String bufferSizeStr = (String) 
marisServerSocketResources.getObject("SOCKET_BUFFER_SIZE");
        buffer_size = (new Integer(bufferSizeStr)).intValue();
        loggingService.debug("BUFFER SIZE = " + buffer_size);
    }
   
    /**
     * This is the infinite loop that continually performs the socket 
operations: accept, read, write
     *
     * @throws MyAppException
     */
    private void setupSocketConnOperations() throws MyAppException{
       
        loggingService.debug("setupSocketConnOperations()");       
        IServer server;
        try {
            InetAddress hostAddress;
            hostAddress = InetAddress.getLocalHost();
            loggingService.debug("xSocket server address: " + 
hostAddress.getHostAddress());
           
            server = new Server(hostAddress, socketPortNo, new 
MultiplexedProtocolAdapter(new CommandPipelineHandler()));
            try {
                ConnectionUtils.start(server);
                loggingService.debug("xSocket server started");
            }
            catch (SocketTimeoutException e) {
                loggingService.debug("SocketTimeoutException starting xSocket 
Server: " + e.getMessage());
            }
        }
        catch (UnknownHostException e) {
            loggingService.debug("UnknownHostException creating xSocket Server: 
" + e.getMessage());
        }
        catch (IOException e) {
            loggingService.debug("IOException creating xSocket Server: " + 
e.getMessage());
        }
    }
}


public class CommandPipelineHandler implements IPipelineDataHandler, 
IConnectHandler {
   
    static private LoggingService LOGGING_SERVICE = new LoggingService();
 
    /* (non-Javadoc)
     * @see 
org.xsocket.connection.multiplexed.IPipelineDataHandler#onData(org.xsocket.connection.multiplexed.INonBlockingPipeline)

     */
    public boolean onData(INonBlockingPipeline pipeline) throws IOException {

        LOGGING_SERVICE.debug("onData()");
        String incomingMessage = pipeline.readStringByLength(126);
        LOGGING_SERVICE.debug("xSocket incomingMessage: " + incomingMessage);
       
        // Pass off to a worker thread:
       
        return true;
    }

    /* (non-Javadoc)
     * @see 
org.xsocket.connection.IConnectHandler#onConnect(org.xsocket.connection.INonBlockingConnection)

     */
    @Override
    public boolean onConnect(INonBlockingConnection arg0) throws IOException,
            BufferUnderflowException, MaxReadSizeExceededException {

        LOGGING_SERVICE.debug("onConnect()");
       
        return true;
    } 
}

Checking through the logs I see that while the server is started, neither of the 
callback methods are invoked i.e. onConnect, onData.

Please advise, maybe I am doing something silly here.

regards,

Sharath