processingservlet.java

21天精通Java,这是一本英文书

package soaprp.processor;

import javax.xml.messaging.*;
import javax.xml.soap.*;
import javax.servlet.*;
import javax.servlet.http.*;
import com.sun.xml.messaging.soaprp.*;

public class ProcessingServlet extends JAXMServlet implements OnewayListener 
{
    private ProviderConnectionFactory factory;
    private ProviderConnection connection;
    private static final String providerURI = "http://java.sun.com/xml/jaxm/provider";

    public void init(ServletConfig servletConfig) throws ServletException 
	{
        super.init(servletConfig);

        try 
		{
	        factory = ProviderConnectionFactory.newInstance();
	        connection = factory.createConnection();
		    setMessageFactory(new SOAPRPMessageFactoryImpl());
		}
		catch (Exception ex)
		{
			throw new ServletException("ProcessingServlet: init: " + ex.getMessage());
		}
	}

    public void onMessage(SOAPMessage message) 
	{
        System.out.println("ProcessingServlet: onMessage: Received message:");
        try 
		{
		    message.saveChanges();
			// Just log the message for now...
            message.writeTo(System.out);
        }
		catch(Exception ex) 
		{
            System.err.println("ProcessingServlet: onMessage: " + ex.getMessage());
        }
    }
}