/Users/nah/Documents/code/cast/src/java/cast/server/LogServer.java

Go to the documentation of this file.

package cast.server;

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 * 
 *      http://www.apache.org/licenses/LICENSE-2.0
 * 
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

//package org.apache.log4j.net;

import java.net.ServerSocket;
import java.net.Socket;

import org.apache.log4j.LogManager;
import org.apache.log4j.Logger;
import org.apache.log4j.PropertyConfigurator;
import org.apache.log4j.net.SocketNode;
import org.apache.log4j.xml.DOMConfigurator;

public class LogServer {

        static Logger cat = Logger.getLogger(LogServer.class);

        static int port;

        public static void main(String argv[]) {
                if (argv.length == 2) {
                        init(argv[0], argv[1]);
                } else {
                        usage("Wrong number of arguments.");
                }

                try {
                        cat.info("Listening on port " + port);
                        ServerSocket serverSocket = new ServerSocket(port);
                        while (true) {
                                cat.info("Waiting to accept a new client.");
                                Socket socket = serverSocket.accept();
                                cat.info("Connected to client at " + socket.getInetAddress());
                                cat.info("Starting new socket node.");
                                new Thread(new SocketNode(socket, LogManager
                                                .getLoggerRepository()), "CAST LogServer:" + port)
                                                .start();
                        }
                } catch (Exception e) {
                        e.printStackTrace();
                }
        }

        static void usage(String msg) {
                System.err.println(msg);
                System.err.println("Usage: java " + LogServer.class.getName()
                                + " port configFile");
                System.exit(1);
        }

        static void init(String portStr, String configFile) {
                try {
                        port = Integer.parseInt(portStr);
                } catch (java.lang.NumberFormatException e) {
                        e.printStackTrace();
                        usage("Could not interpret port number [" + portStr + "].");
                }

                if (configFile.endsWith(".xml")) {
                        DOMConfigurator.configure(configFile);
                } else {
                        PropertyConfigurator.configure(configFile);
                }
        }
}

---