001 /** 002 * 003 * Copyright 2004 Protique Ltd 004 * 005 * Licensed under the Apache License, Version 2.0 (the "License"); 006 * you may not use this file except in compliance with the License. 007 * You may obtain a copy of the License at 008 * 009 * http://www.apache.org/licenses/LICENSE-2.0 010 * 011 * Unless required by applicable law or agreed to in writing, software 012 * distributed under the License is distributed on an "AS IS" BASIS, 013 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 014 * See the License for the specific language governing permissions and 015 * limitations under the License. 016 * 017 **/ 018 package org.codehaus.activesoap.handler; 019 020 import org.codehaus.activesoap.Handler; 021 import org.codehaus.activesoap.MessageExchange; 022 import org.codehaus.activesoap.SoapService; 023 import org.codehaus.activesoap.HandlerRegistry; 024 import org.codehaus.activesoap.HandlerRegistry; 025 import org.codehaus.activesoap.soap.SoapVersion; 026 027 import javax.xml.stream.XMLStreamReader; 028 import javax.xml.stream.XMLStreamWriter; 029 030 /** 031 * A handler which processes a SOAP envelope using a specific SOAP protocol. 032 * 033 * @version $Revision: 1.7 $ 034 */ 035 public class SoapHandler implements Handler { 036 private SoapVersion soap; 037 038 public SoapHandler(SoapVersion soap) { 039 this.soap = soap; 040 } 041 042 /** 043 * Helper method to register this handler with the registry 044 * 045 * @param registry 046 */ 047 public void register(HandlerRegistry registry) { 048 registry.addHandler(soap.getEnvelope(), this); 049 } 050 051 public void invoke(MessageExchange exchange) throws Exception { 052 XMLStreamReader in = exchange.getIn(); 053 XMLStreamWriter out = exchange.getOut(); 054 SoapService soapService = exchange.getSoapService(); 055 if (soapService == null) { 056 throw new IllegalArgumentException("Cannot invoke a SoapHandler in a pure REST service; you need to use a SoapService"); 057 } 058 SoapRequestHandler instance = new SoapRequestHandler(soapService, soap); 059 instance.invoke(exchange.newInstance(in, out)); 060 } 061 }