FEServer.java

import org.apache.log4j.BasicConfigurator;
import org.apache.log4j.Logger;

import org.apache.thrift.TProcessorFactory;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.server.TThreadPoolServer;
import org.apache.thrift.transport.TServerSocket;
import org.apache.thrift.transport.layered.TFramedTransport;

public class FEServer {
    static Logger log;

    public static void main(String[] args) throws Exception {
        if (args.length != 1) {
            System.err.println("Usage: java FEServer FE_port");
            System.exit(-1);
        }

        BasicConfigurator.configure();
        log = Logger.getLogger(FEServer.class.getName());

        int portFE = Integer.parseInt(args[0]);
        log.info("Launching FE on port " + portFE);

        MiningPoolServiceHandler handler = new MiningPoolServiceHandler(false);
        MiningPoolService.Processor processor = new MiningPoolService.Processor(handler);

        TServerSocket socket = new TServerSocket(portFE);
        TThreadPoolServer.Args sargs = new TThreadPoolServer.Args(socket)
                .protocolFactory(new TBinaryProtocol.Factory())
                .transportFactory(new TFramedTransport.Factory())
                .processorFactory(new TProcessorFactory(processor));
        TThreadPoolServer server = new TThreadPoolServer(sargs);

        server.serve();
    }
}