Package org.mortbay.http

Examples of org.mortbay.http.SocketListener


        // configure the listeners/loggers
        for (ContainerConfig.Container.Property props: serverConfig.properties.values()) {
            if ("listener".equals(props.value)) {
                if ("default".equals(props.getProperty("type").value)) {
                    SocketListener listener = new SocketListener();
                    setListenerOptions(listener, props);
                    if (props.getProperty("identify-listener") != null) {
                        boolean identifyListener = "true".equalsIgnoreCase(props.getProperty("identify-listener").value);
                        listener.setIdentifyListener(identifyListener);
                    }
                    if (props.getProperty("buffer-size") != null) {
                        int value = 0;
                        try {
                            value = Integer.parseInt(props.getProperty("buffer-size").value);
                        } catch (NumberFormatException e) {
                            value = 0;
                        }
                        if (value > 0) {
                            listener.setBufferSize(value);
                        }
                    }
                    if (props.getProperty("low-resource-persist-time") != null) {
                        int value = 0;
                        try {
                            value = Integer.parseInt(props.getProperty("low-resource-persist-time").value);
                        } catch (NumberFormatException e) {
                            value = 0;
                        }
                        if (value > 0) {
                            listener.setLowResourcePersistTimeMs(value);
                        }
                    }
                    server.addListener(listener);
                } else if ("sun-jsse".equals(props.getProperty("type").value)) {
                    SunJsseListener listener = new SunJsseListener();
                    setListenerOptions(listener, props);
                    if (props.getProperty("keystore") != null) {
                        listener.setKeystore(props.getProperty("keystore").value);
                    }
                    if (props.getProperty("password") != null) {
                        listener.setPassword(props.getProperty("password").value);
                    }
                    if (props.getProperty("key-password") != null) {
                        listener.setKeyPassword(props.getProperty("key-password").value);
                    }
                    if (props.getProperty("need-client-auth") != null) {
                        boolean needClientAuth = "true".equalsIgnoreCase(props.getProperty("need-client-auth").value);
                        listener.setNeedClientAuth(needClientAuth);
                    }
                    if (props.getProperty("identify-listener") != null) {
                        boolean identifyListener = "true".equalsIgnoreCase(props.getProperty("identify-listener").value);
                        listener.setIdentifyListener(identifyListener);
                    }
                    if (props.getProperty("buffer-size") != null) {
                        int value = 0;
                        try {
                            value = Integer.parseInt(props.getProperty("buffer-size").value);
                        } catch (NumberFormatException e) {
                            value = 0;
                        }
                        if (value > 0) {
                            listener.setBufferSize(value);
                        }
                    }
                    if (props.getProperty("low-resource-persist-time") != null) {
                        int value = 0;
                        try {
                            value = Integer.parseInt(props.getProperty("low-resource-persist-time").value);
                        } catch (NumberFormatException e) {
                            value = 0;
                        }
                        if (value > 0) {
                            listener.setLowResourcePersistTimeMs(value);
                        }
                    }
                    server.addListener(listener);
                } else if ("ibm-jsse".equals(props.getProperty("type").value)) {
                    throw new ContainerException("Listener not supported yet [" + props.getProperty("type").value + "]");
                } else if ("nio".equals(props.getProperty("type").value)) {
                    throw new ContainerException("Listener not supported yet [" + props.getProperty("type").value + "]");
                } else if ("ajp13".equals(props.getProperty("type").value)) {
                    AJP13Listener listener = new AJP13Listener();
                    setListenerOptions(listener, props);
                    if (props.getProperty("identify-listener") != null) {
                        boolean identifyListener = "true".equalsIgnoreCase(props.getProperty("identify-listener").value);
                        listener.setIdentifyListener(identifyListener);
                    }
                    if (props.getProperty("buffer-size") != null) {
                        int value = 0;
                        try {
                            value = Integer.parseInt(props.getProperty("buffer-size").value);
                        } catch (NumberFormatException e) {
                            value = 0;
                        }
                        if (value > 0) {
                            listener.setBufferSize(value);
                        }
                    }
                    server.addListener(listener);
                }
            } else if ("request-log".equals(props.value)) {
View Full Code Here


    public static void main(final String[] args) throws Exception {
        //A Thread for Jetty...
        new Thread(new Runnable() {
            public void run() {
                Server server = new Server();
                SocketListener listener = new SocketListener();
                listener.setPort(parseWebPort(args));
                System.setProperty("ccname", parseCCName(args));
                server.addListener(listener);
                try {
                    server.addWebApplication("cruisecontrol", parseCCHome(args) + "/webapps/cruisecontrol");
                } catch (IOException e) {
View Full Code Here

    {
        try
        {
            Server server = new Server();

            SocketListener socketListener = new SocketListener();
            socketListener.setPort(_port);
            server.addListener(socketListener);

            NCSARequestLog log = new NCSARequestLog();
            server.setRequestLog(log);
View Full Code Here

            readUserCommands();
        }
    }

    protected void createJettyServer(boolean slowResources) {
        final SocketListener socketListener;

        server = new Server();
        socketListener = new SocketListener();
        socketListener.setMaxIdleTimeMs(60000);
        socketListener.setMaxThreads(jettyThreads);
        socketListener.setPort(getPort());
        server.addListener(socketListener);
        configServer();
        assembleHandlers(slowResources, configuration);
    }
View Full Code Here

        public void doStart() throws WaitingException, Exception {
            HttpListener tmpListener;
            try {
                if (null == protocol || protocol.equalsIgnoreCase(HTTP_PROTOCOL)) {
                    tmpListener = new SocketListener();
                } else if (protocol.equalsIgnoreCase(AJP13_PROTOCOL)) {
                    tmpListener = new AJP13Listener();
                } else if (protocol.equalsIgnoreCase(HTTPS_PROTOCOL)) {
                    tmpListener = new SunJsseListener();
                } else {
View Full Code Here

/**
* @version $Rev: 56022 $ $Date: 2004-10-30 00:16:18 -0500 (Sat, 30 Oct 2004) $
*/
public class HTTPConnector extends JettyConnector {
    public HTTPConnector(JettyContainer container) {
        super(container, new SocketListener());
    }
View Full Code Here

      server = null;
    }
    server = new HttpServer();
 
    // Create a port listener
    SocketListener listener=new SocketListener();
    listener.setPort(8080);
    server.addListener(listener);
    }
View Full Code Here

   */
  public StatusHttpServer(String name, int port,
                          boolean findPort) throws IOException {
    webServer = new org.mortbay.jetty.Server();
    this.findPort = findPort;
    listener = new SocketListener();
    listener.setPort(port);
    webServer.addListener(listener);

    // set up the context for "/logs/"
    HttpContext logContext = new HttpContext();
View Full Code Here

*
* @version $Revision: 1.3 $ $Date: 2004/03/10 09:58:56 $
*/
public class HTTPConnector extends JettyConnector {
    public HTTPConnector(JettyContainer container) {
        super(container, new SocketListener());
    }
View Full Code Here

        public void doStart() throws WaitingException, Exception {
            HttpListener tmpListener;
            try {
                if (null == protocol || protocol.equalsIgnoreCase(HTTP_PROTOCOL)) {
                    tmpListener = new SocketListener();
                } else if (protocol.equalsIgnoreCase(AJP13_PROTOCOL)) {
                    tmpListener = new AJP13Listener();
                } else if (protocol.equalsIgnoreCase(HTTPS_PROTOCOL)) {
                    tmpListener = new SunJsseListener();
                } else {
View Full Code Here

TOP

Related Classes of org.mortbay.http.SocketListener

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.