httpadaptor.java

java pos,你可以直接编译运行,

/*
 * Copyright (c) 2004 jPOS.org 
 *
 * See terms of license at http://jpos.org/license.html
 *
 */
package org.jpos.q2.qbean;

import java.net.URL;

import org.jpos.q2.Q2;
import org.jpos.q2.QBean;
import org.jpos.q2.QBeanSupport;
import org.jpos.q2.QClassLoader;
import org.jpos.q2.QPersist;
import org.jdom.Element;
import org.jpos.util.Log;
import org.jpos.util.Logger;

import javax.management.*;

/**
 * @author <a href="mailto:[e-mail]">Alireza Taherkordi</a>
 * @author Alejandro Revilla
 *
 * <http-adaptor class="org.jpos.q2.qbean.HttpAdaptor" name="http-adaptor" >
 *  <attr name="host">localhost</attr>
 *  <attr name="port" type="java.lang.Integer">8082</attr>
 * </http-adaptor>
 *
 * set host property to "localhost" if you want to can't access the server
 * from another computer,This is good for security reasons.
 *
 * @version $Revision: 1.4 $ $Date: 2004/05/05 00:06:32 $
 */
public class HttpAdaptor
            extends mx4j.tools.adaptor.http.HttpAdaptor
        implements  HttpAdaptorMBean , QBean, QPersist
{
    Element persist;
    int state;
    Q2 server;
    String name, loggerName, user, password;
    boolean modified;
    ObjectName processorName;
    Log log;

    public HttpAdaptor () {
        super();
        state = -1;
    }
    public void setServer (Q2 server) {
        this.server = server;
    }
    public Q2 getServer () {
        return server;
    }
    public void setName (String name) {
        this.name = name;
        setModified (true);
    }
    public String getName () {
        return name;
    }
    public void setUser (String user) {
        this.user = user;
    }
    public String getUser () {
        return user;
    }
    public void setPassword (String password) {
        this.password = password;
    }
    public void setLogger (String loggerName) {
        this.loggerName = loggerName;
        log = new Log (Logger.getLogger (loggerName), getName ());
        setModified (true);
    }

    public String getLogger () 
    {
        return log.getLogger().getName();
    }

    public void init ()
    {
        if (state != -1)
            return;
        try {
            setModified (false);
            processorName = new ObjectName("MX4J:name=mx4j.tools.adaptor.http.XSLTProcessor");
            mx4j.tools.adaptor.http.XSLTProcessor processorMBean = new mx4j.tools.adaptor.http.XSLTProcessor();
            getServer().getMBeanServer().registerMBean(processorMBean,processorName);
            setProcessorName(processorName);
            if (user != null && password != null) {
                addAuthorization(user, password);
                setAuthenticationMethod ("basic");
            }
            state = QBean.STOPPED;
        } catch (Exception e) {
            if (log != null)
                log.warn ("init", e);
        }

    }
    public void start()
    {
        if (state != QBean.DESTROYED &&
            state != QBean.STOPPED   &&
            state != QBean.FAILED)
           return;

        this.state = QBean.STARTING;

        try {
           super.start();
        } catch (Throwable t) {
           state = QBean.FAILED;
           t.printStackTrace();
           return;
        }
        state = QBean.STARTED;
    }
    public void stop ()
    {
        if (state != QBean.STARTED)
           return;
        state = QBean.STOPPING;
        try {
           super.stop();
        } catch (Throwable t) {
           state = QBean.FAILED;
           t.printStackTrace();
           return;
        }
        state = QBean.STOPPED;
    }
    public void destroy ()
    {
        if (state == QBean.DESTROYED)
           return;
        if (state != QBean.STOPPED)
           stop();

        try {
            getServer().getMBeanServer().unregisterMBean(processorName);
        } catch (Exception e) {
            if (log != null)
                log.warn ("destroy", e);
        }

        state = QBean.DESTROYED;
    }
    public int getState () {
        return state;
    }
    public String getStateAsString () {
        return QBeanSupport.stateString[state];
    }
    public void setState (int state) {
        this.state = state;
    }
    public void setPersist (Element persist) {
        this.persist = persist ;
    }

    private Element createAttr (String name, String value, String type) {
        Element e = new Element ("attr");
        e.setAttribute ("name", name);
        if (type != null)
            e.setAttribute ("type", type);
        e.setText (value);
        return e;
    }
    private Element createAttr (String name, String value) {
        return createAttr (name, value, null);
    }
    public synchronized Element getPersist () {
        setModified (false);
        Element e = new Element (persist.getName());
        Element classPath = persist.getChild ("classpath");
        if (classPath != null)
            e.addContent (classPath);
        e.setAttribute ("class", getClass().getName());
        if (!e.getName().equals (getName ()))
            e.setAttribute ("name", getName());
        if (loggerName != null)
            e.setAttribute ("logger", loggerName);
        e.addContent (
            createAttr ("host", getHost())
        );
        e.addContent (
            createAttr (
                "port", Integer.toString (getPort()), "java.lang.Integer")
        );
        if (user != null && password != null) {
            e.addContent (createAttr ("user", user));
            e.addContent (createAttr ("password", password));
        }
        return (persist = e);
    }
    public synchronized void setModified (boolean modified) {
        this.modified = modified;
    }
    public synchronized boolean isModified () {
        return modified;
    }
    protected boolean running () {
        return state == QBean.STARTING || state == QBean.STARTED;
    }
    public void setHost (String host) {
        setModified (true);
        super.setHost (host);
    }
    public void setPort (int port) {
        setModified (true);
        super.setPort (port);
    }
    public void shutdownQ2 () {
        getServer().shutdown ();
    }
    /**
     * Not implemented.
     * @see org.jpos.q2.QBeanSupportMBean#getLoaderURLS()
     */
    public URL[] getLoaderURLS() {
        return null;
    }
    /**
     * Not implemented.
     * @see org.jpos.q2.QBeanSupportMBean#getLoader()
     */
    public QClassLoader getLoader() {
        return null;
    }
}