basicconnectionserver.java

the source code of voyager examples---connnection

// (c) Copyright 2003 Recursion Software, Inc.

package examples.connectionmgmt;

import com.recursionsw.ve.Namespace;
import com.recursionsw.ve.Proxy;
import com.recursionsw.ve.Voyager;
import com.recursionsw.ve.tcp.BasicConnectionManagementPolicy;
import com.recursionsw.ve.transport.Transport;

import examples.stockmarket.IStockmarket;

public class BasicConnectionServer {
    public static void main(String[] args) {
        try {
            Voyager.startup();
            // Create a connection policy as follows: unlimited open client connects, max of 3
            // open server connects, unlimited idle connects, unlimited client connect idle time,
            // ten second server connect idle time.
            Transport.registerConnectionManagementPolicy(
                "tcp",
                new BasicConnectionManagementPolicy(-1, 3, -1, 0, 2000));
            // Add a listener to watch for open/close connection
            Transport.addEventListener(new ConnectionListener());
            // Export stockmarket to port 9000
            IStockmarket market =
                (IStockmarket) Proxy.export(new DelayedStockmarket(), "9000");
            // bind "NASDAQ" to the stockmarket
            Namespace.bind("9000/NASDAQ", market);
        } catch (Exception exception) {
            System.err.println(exception);
        }
    }
}