http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/cxf/cxf-binding-nmr/src/main/java/org/apache/servicemix/cxf/binding/nmr/interceptors/NMRWrapperInInterceptor.java ---------------------------------------------------------------------- diff --git a/cxf/cxf-binding-nmr/src/main/java/org/apache/servicemix/cxf/binding/nmr/interceptors/NMRWrapperInInterceptor.java b/cxf/cxf-binding-nmr/src/main/java/org/apache/servicemix/cxf/binding/nmr/interceptors/NMRWrapperInInterceptor.java deleted file mode 100644 index 29c7d3d..0000000 --- a/cxf/cxf-binding-nmr/src/main/java/org/apache/servicemix/cxf/binding/nmr/interceptors/NMRWrapperInInterceptor.java +++ /dev/null @@ -1,139 +0,0 @@ -/** - * 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.servicemix.cxf.binding.nmr.interceptors; - -import java.util.ArrayList; -import java.util.List; -import java.util.ResourceBundle; -import java.util.logging.Logger; - -import javax.xml.namespace.QName; -import javax.xml.stream.XMLStreamConstants; -import javax.xml.stream.XMLStreamException; -import javax.xml.stream.XMLStreamReader; - -import org.apache.servicemix.cxf.binding.nmr.NMRBindingInfo; -import org.apache.servicemix.cxf.binding.nmr.NMRConstants; -import org.apache.servicemix.cxf.binding.nmr.NMRFault; -import org.apache.cxf.common.logging.LogUtils; -import org.apache.cxf.databinding.DataReader; -import org.apache.cxf.endpoint.Endpoint; -import org.apache.cxf.interceptor.AbstractInDatabindingInterceptor; -import org.apache.cxf.interceptor.Fault; -import org.apache.cxf.message.Exchange; -import org.apache.cxf.message.Message; -import org.apache.cxf.phase.Phase; -import org.apache.cxf.service.model.BindingInfo; -import org.apache.cxf.service.model.BindingMessageInfo; -import org.apache.cxf.service.model.BindingOperationInfo; -import org.apache.cxf.service.model.MessageInfo; -import org.apache.cxf.service.model.MessagePartInfo; -import org.apache.cxf.staxutils.DepthXMLStreamReader; -import org.apache.cxf.staxutils.StaxUtils; - -public class NMRWrapperInInterceptor extends AbstractInDatabindingInterceptor { - - private static final Logger LOG = LogUtils.getL7dLogger(NMRWrapperInInterceptor.class); - - private static final ResourceBundle BUNDLE = LOG.getResourceBundle(); - - public NMRWrapperInInterceptor() { - super(Phase.UNMARSHAL); - } - - public void handleMessage(Message message) throws Fault { - if (isGET(message)) { - LOG.fine("JbiMessageInInterceptor skipped in HTTP GET method"); - return; - } - XMLStreamReader xsr = message.getContent(XMLStreamReader.class); - - DepthXMLStreamReader reader = new DepthXMLStreamReader(xsr); - - Endpoint ep = message.getExchange().get(Endpoint.class); - BindingInfo binding = ep.getEndpointInfo().getBinding(); - if (!(binding instanceof NMRBindingInfo)) { - throw new IllegalStateException( - new org.apache.cxf.common.i18n.Message("NEED_JBIBINDING", BUNDLE).toString()); - } - - if (!StaxUtils.toNextElement(reader)) { - throw new Fault(new org.apache.cxf.common.i18n.Message("NO_OPERATION_ELEMENT", BUNDLE)); - } - - Exchange ex = message.getExchange(); - QName startQName = reader.getName(); - - // handling jbi fault message - if (startQName.getLocalPart().equals(NMRFault.NMR_FAULT_ROOT)) { - message.getInterceptorChain().abort(); - - if (ep.getInFaultObserver() != null) { - ep.getInFaultObserver().onMessage(message); - return; - } - } - - - // handling xml normal inbound message - if (!startQName.equals(NMRConstants.JBI_WRAPPER_MESSAGE)) { - throw new Fault(new org.apache.cxf.common.i18n.Message( - "NO_JBI_MESSAGE_ELEMENT", BUNDLE)); - } - - try { - BindingOperationInfo bop = ex.get(BindingOperationInfo.class); - DataReader<XMLStreamReader> dr = getDataReader(message); - List<Object> parameters = new ArrayList<Object>(); - reader.next(); - BindingMessageInfo messageInfo = !isRequestor(message) ? bop.getInput() : bop.getOutput(); - message.put(MessageInfo.class, messageInfo.getMessageInfo()); - for (MessagePartInfo part : messageInfo.getMessageParts()) { - if (!StaxUtils.skipToStartOfElement(reader)) { - throw new Fault(new org.apache.cxf.common.i18n.Message("NOT_ENOUGH_PARTS", BUNDLE)); - } - startQName = reader.getName(); - if (!startQName.equals(NMRConstants.JBI_WRAPPER_PART)) { - throw new Fault(new org.apache.cxf.common.i18n.Message("NO_JBI_PART_ELEMENT", BUNDLE)); - } - if (part.isElement()) { - reader.next(); - if (!StaxUtils.toNextElement(reader)) { - throw new Fault(new org.apache.cxf.common.i18n.Message("EXPECTED_ELEMENT_IN_PART", BUNDLE)); - } - } - parameters.add(dr.read(part, reader)); - // skip end element - if (part.isElement()) { - reader.next(); - } - } - int ev = reader.getEventType(); - while (ev != XMLStreamConstants.END_ELEMENT - && ev != XMLStreamConstants.START_ELEMENT - && ev != XMLStreamConstants.END_DOCUMENT) { - ev = reader.next(); - } - message.setContent(List.class, parameters); - } catch (XMLStreamException e) { - throw new Fault(new org.apache.cxf.common.i18n.Message("STAX_READ_EXC", BUNDLE), e); - } - } - -}
http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/cxf/cxf-binding-nmr/src/main/java/org/apache/servicemix/cxf/binding/nmr/interceptors/NMRWrapperOutInterceptor.java ---------------------------------------------------------------------- diff --git a/cxf/cxf-binding-nmr/src/main/java/org/apache/servicemix/cxf/binding/nmr/interceptors/NMRWrapperOutInterceptor.java b/cxf/cxf-binding-nmr/src/main/java/org/apache/servicemix/cxf/binding/nmr/interceptors/NMRWrapperOutInterceptor.java deleted file mode 100644 index 35d5305..0000000 --- a/cxf/cxf-binding-nmr/src/main/java/org/apache/servicemix/cxf/binding/nmr/interceptors/NMRWrapperOutInterceptor.java +++ /dev/null @@ -1,102 +0,0 @@ -/** - * 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.servicemix.cxf.binding.nmr.interceptors; - -import java.util.List; -import java.util.ResourceBundle; -import java.util.logging.Logger; - -import javax.xml.stream.XMLStreamException; -import javax.xml.stream.XMLStreamWriter; - -import org.apache.cxf.common.logging.LogUtils; -import org.apache.cxf.databinding.DataWriter; -import org.apache.cxf.interceptor.AbstractOutDatabindingInterceptor; -import org.apache.cxf.interceptor.Fault; -import org.apache.cxf.message.Message; -import org.apache.cxf.phase.Phase; -import org.apache.cxf.service.Service; -import org.apache.cxf.service.model.BindingOperationInfo; -import org.apache.cxf.service.model.MessagePartInfo; -import org.apache.servicemix.cxf.binding.nmr.NMRConstants; - -public class NMRWrapperOutInterceptor extends AbstractOutDatabindingInterceptor { - - private static final Logger LOG = LogUtils.getL7dLogger(NMRWrapperOutInterceptor.class); - - private static final ResourceBundle BUNDLE = LOG.getResourceBundle(); - - public NMRWrapperOutInterceptor() { - super(Phase.MARSHAL); - } - - public void handleMessage(Message message) throws Fault { - BindingOperationInfo bop = message.getExchange().get(BindingOperationInfo.class); - XMLStreamWriter xmlWriter = getXMLStreamWriter(message); - Service service = message.getExchange().get(Service.class); - - DataWriter<XMLStreamWriter> dataWriter = getDataWriter(message, service, XMLStreamWriter.class); - - try { - xmlWriter.setPrefix("jbi", NMRConstants.NS_JBI_WRAPPER); - xmlWriter.writeStartElement(NMRConstants.NS_JBI_WRAPPER, - NMRConstants.JBI_WRAPPER_MESSAGE.getLocalPart()); - xmlWriter.writeNamespace("jbi", NMRConstants.NS_JBI_WRAPPER); - - List<MessagePartInfo> parts = null; - if (!isRequestor(message)) { - parts = bop.getOutput().getMessageParts(); - } else { - parts = bop.getInput().getMessageParts(); - } - List<?> objs = (List<?>) message.getContent(List.class); - if (objs.size() < parts.size()) { - throw new Fault(new org.apache.cxf.common.i18n.Message( - "NOT_EQUAL_ARG_NUM", BUNDLE)); - } - for (int idx = 0; idx < parts.size(); idx++) { - MessagePartInfo part = parts.get(idx); - Object obj = objs.get(idx); - if (!part.isElement()) { - if (part.getTypeClass() == String.class) { - xmlWriter.writeStartElement(NMRConstants.NS_JBI_WRAPPER, - NMRConstants.JBI_WRAPPER_PART.getLocalPart()); - xmlWriter.writeCharacters(obj.toString()); - xmlWriter.writeEndElement(); - } else { - part = new MessagePartInfo(part.getName(), part.getMessageInfo()); - part.setElement(false); - part.setConcreteName(NMRConstants.JBI_WRAPPER_PART); - dataWriter.write(obj, part, xmlWriter); - } - } else { - xmlWriter.writeStartElement(NMRConstants.NS_JBI_WRAPPER, - NMRConstants.JBI_WRAPPER_PART.getLocalPart()); - dataWriter.write(obj, part, xmlWriter); - xmlWriter.writeEndElement(); - } - } - xmlWriter.writeEndElement(); - - } catch (XMLStreamException e) { - throw new Fault(new org.apache.cxf.common.i18n.Message("STAX_WRITE_EXC", BUNDLE), e); - } - } - -} http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/cxf/cxf-binding-nmr/src/main/resources/META-INF/cxf/binding/nmr/cxf-binding-nmr.xml ---------------------------------------------------------------------- diff --git a/cxf/cxf-binding-nmr/src/main/resources/META-INF/cxf/binding/nmr/cxf-binding-nmr.xml b/cxf/cxf-binding-nmr/src/main/resources/META-INF/cxf/binding/nmr/cxf-binding-nmr.xml deleted file mode 100644 index 45e4a62..0000000 --- a/cxf/cxf-binding-nmr/src/main/resources/META-INF/cxf/binding/nmr/cxf-binding-nmr.xml +++ /dev/null @@ -1,36 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<!-- - 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. ---> -<beans xmlns="http://www.springframework.org/schema/beans"; - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; - xsi:schemaLocation=" -http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd";> - - <bean class="org.apache.servicemix.cxf.binding.nmr.NMRBindingFactory" - id="org.apache.servicemix.cxf.binding.nmr.NMRBindingFactory" - lazy-init="true"> - <property name="bus" ref="cxf"/> - <property name="activationNamespaces"> - <set> - <value>http://cxf.apache.org/bindings/nmr</value> - </set> - </property> - </bean> - -</beans> http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/cxf/cxf-binding-nmr/src/main/resources/org/apache/servicemix/cxf/binding/nmr/interceptors/Messages.properties ---------------------------------------------------------------------- diff --git a/cxf/cxf-binding-nmr/src/main/resources/org/apache/servicemix/cxf/binding/nmr/interceptors/Messages.properties b/cxf/cxf-binding-nmr/src/main/resources/org/apache/servicemix/cxf/binding/nmr/interceptors/Messages.properties deleted file mode 100644 index 1dc5ac4..0000000 --- a/cxf/cxf-binding-nmr/src/main/resources/org/apache/servicemix/cxf/binding/nmr/interceptors/Messages.properties +++ /dev/null @@ -1,61 +0,0 @@ -# -# 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. -# -NOT.IMPLEMENTED=not yet implemented -INVOKE.SERVICE=invoking service\t -CREATE.MESSAGE.EXCHANGE=create message exchange svc:\t -EXCHANGE.ENDPOINT=exchange endpoint:\t -NO.MESSAGE=no message yet -UNABLE.RETRIEVE.MESSAGE=unable to retrieve message -CONTEXT.MUST.BE=context must be of type JBIOutputStreamMessageContext -RECEIVED.MESSAGE=received message:\t -ACTIVE.JBI.SERVER.TRANSPORT=activating JBI server transport -BUILDING.DOCUMENT=building document from bytes -CREATE.NORMALIZED.MESSAGE=creating NormalizedMessage -POST.DISPATCH=postDispatch sending out message to NWR -ERROR.SEND.MESSAGE=error sending Out message -DISPATCH.MESSAGE.ON.CALLBACK=dispatching message on callback:\t -ERROR.PREPARE.MESSAGE=error preparing message -RECEIVE.THREAD.START=JBIServerTransport message receiving thread started -DISPATCH.TO.SU=dispatching to CXF service unit -NO.SU.FOUND=no CXFServiceUnit found -ERROR.DISPATCH.THREAD=error running dispatch thread -JBI.SERVER.TRANSPORT.MESSAGE.PROCESS.THREAD.EXIT=JBIServerTransport message processing thread exiting -CONFIG.DELIVERY.CHANNEL=configuring DeliveryChannel:\t -CONFIG.SU.MANAGER=configuring ServiceUnitManager:\t -JBI.TRANSPORT.FACTORY.NOT.INITIALIZED=JBITransportFactory is not properly initialized -SU.MANAGER=CXFServiceUnitManager:\t -DELIVERY.CHANNEL=DeliveryChannel:\t -JBI.TRANSPORT.FACTORY.NOT.FULLY.INITIALIZED=JBITransport factory not fully initialized -CREATE.SERVER.TRANSPORT=creating JBI server transport -CREATE.CLIENT.TRANSPORT=creating JBI client transport -UNKNOWN_OPERATION=unknown operation {0} -NO_OPERATION_ELEMENT=no operation element -NO_JBI_MESSAGE_ELEMENT=no jbi message element -NOT_ENOUGH_PARTS=not enough parts -NO_JBI_PART_ELEMENT=no jbi part element -EXPECTED_ELEMENT_IN_PART=expected element in part -TOO_MANY_PARTS=too many parts -ILLEGAL_JBIFAULT_FORMAT=illegal jbi fault format -STAX_READ_EXC=stax read exception -XML_WRITE_EXC=xml write exception -STAX_WRITE_EXC=stax write exception -NOT_EQUAL_ARG_NUM=The number of arguments is not equal -NEED_JBIBINDING=BindingInfo should be a JbiBindingInfo -NO_EXCEPTION=No exception on this message -NO_XML_STREAM_WRITER=No XMLStreamWriter on this message http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/GreeterImpl.java ---------------------------------------------------------------------- diff --git a/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/GreeterImpl.java b/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/GreeterImpl.java deleted file mode 100644 index 6246d45..0000000 --- a/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/GreeterImpl.java +++ /dev/null @@ -1,55 +0,0 @@ -/** - * 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.servicemix.cxf.binding.nmr; - -import javax.jws.WebService; - -import org.apache.hello_world.nmr.Greeter; -import org.apache.hello_world.nmr.PingMeFault; -import org.apache.hello_world.types.nmr.FaultDetail; - - -@WebService(serviceName = "HelloWorldService", - portName = "SoapPort", - endpointInterface = "org.apache.hello_world.nmr.Greeter", - targetNamespace = "http://apache.org/hello_world/nmr"; - ) -public class GreeterImpl implements Greeter { - - public String sayHi() { - return "Bonjour"; - } - - public String greetMe(String requestType) { - return "Hello " + requestType; - } - - public void greetMeOneWay(String requestType) { - System.out.println("OneWay get invoked"); - } - - public void pingMe() throws PingMeFault { - FaultDetail faultDetail = new FaultDetail(); - faultDetail.setMajor((short)2); - faultDetail.setMinor((short)1); - throw new PingMeFault("PingMeFault raised by server", faultDetail); - - } - -} http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/HackOperationInterceptor.java ---------------------------------------------------------------------- diff --git a/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/HackOperationInterceptor.java b/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/HackOperationInterceptor.java deleted file mode 100644 index f127f7a..0000000 --- a/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/HackOperationInterceptor.java +++ /dev/null @@ -1,53 +0,0 @@ -/* - * 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.servicemix.cxf.binding.nmr; - -import javax.xml.namespace.QName; - -import org.apache.cxf.interceptor.Fault; -import org.apache.cxf.phase.AbstractPhaseInterceptor; -import org.apache.cxf.phase.Phase; -import org.apache.servicemix.cxf.binding.nmr.interceptors.NMROperationInInterceptor; -import org.apache.servicemix.nmr.api.Exchange; -import org.apache.servicemix.nmr.api.Pattern; -import org.apache.servicemix.nmr.core.ExchangeImpl; - -public class HackOperationInterceptor extends AbstractPhaseInterceptor<NMRMessage> { - - private int index = 1; - - public HackOperationInterceptor() { - super(Phase.PRE_PROTOCOL); - addBefore(NMROperationInInterceptor.class.getName()); - } - - public void handleMessage(NMRMessage message) throws Fault { - ExchangeImpl exchange = new ExchangeImpl(Pattern.InOut); - - if (index == 1) { - exchange.setOperation(new QName("http://apache.org/hello_world/nmr";, "greetMe")); - index++; - } else if (index == 2) { - exchange.setOperation(new QName("http://apache.org/hello_world/nmr";, "sayHi")); - index++; - } else if (index == 3) { - exchange.setOperation(new QName("http://apache.org/hello_world/nmr";, "pingMe")); - index++; - } - message.put(Exchange.class, exchange); - } -} http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/NMRBindingFactoryTest.java ---------------------------------------------------------------------- diff --git a/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/NMRBindingFactoryTest.java b/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/NMRBindingFactoryTest.java deleted file mode 100644 index 7000406..0000000 --- a/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/NMRBindingFactoryTest.java +++ /dev/null @@ -1,56 +0,0 @@ -/** - * 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.servicemix.cxf.binding.nmr; - - -import org.apache.cxf.binding.Binding; -import org.apache.cxf.interceptor.StaxOutInterceptor; -import org.apache.cxf.service.model.ServiceInfo; -import org.apache.servicemix.cxf.binding.nmr.interceptors.NMRFaultOutInterceptor; -import org.apache.servicemix.cxf.binding.nmr.interceptors.NMROperationInInterceptor; -import org.apache.servicemix.cxf.binding.nmr.interceptors.NMRWrapperInInterceptor; -import org.apache.servicemix.cxf.binding.nmr.interceptors.NMRWrapperOutInterceptor; -import org.junit.Assert; -import org.junit.Test; - -public class NMRBindingFactoryTest extends Assert { - - @Test - public void testCreateBinding() { - - NMRBindingInfo info = new NMRBindingInfo(new ServiceInfo(), "id"); - Binding binding = new NMRBindingFactory().createBinding(info); - assertEquals(3, binding.getInInterceptors().size()); - //assertEquals(?, binding.getInFaultInterceptors().size()); - assertEquals(2, binding.getOutInterceptors().size()); - assertEquals(2, binding.getOutFaultInterceptors().size()); - assertEquals(NMROperationInInterceptor.class.getName(), - binding.getInInterceptors().get(1).getClass().getName()); - assertEquals(NMRWrapperInInterceptor.class.getName(), - binding.getInInterceptors().get(2).getClass().getName()); - assertEquals(StaxOutInterceptor.class.getName(), - binding.getOutInterceptors().get(0).getClass().getName()); - assertEquals(NMRWrapperOutInterceptor.class.getName(), - binding.getOutInterceptors().get(1).getClass().getName()); - assertEquals(StaxOutInterceptor.class.getName(), - binding.getOutFaultInterceptors().get(0).getClass().getName()); - assertEquals(NMRFaultOutInterceptor.class.getName(), - binding.getOutFaultInterceptors().get(1).getClass().getName()); - } -} http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/NMRClientServerTest.java ---------------------------------------------------------------------- diff --git a/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/NMRClientServerTest.java b/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/NMRClientServerTest.java deleted file mode 100644 index 194e2a9..0000000 --- a/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/NMRClientServerTest.java +++ /dev/null @@ -1,81 +0,0 @@ -/** - * 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.servicemix.cxf.binding.nmr; - -import java.net.URL; - -import javax.xml.namespace.QName; - -import org.apache.cxf.Bus; -import org.apache.cxf.configuration.Configurer; -import org.apache.cxf.configuration.spring.ConfigurerImpl; -import org.apache.cxf.test.TestApplicationContext; -import org.apache.cxf.testutil.common.AbstractClientServerTestBase; -import org.apache.hello_world.nmr.Greeter; -import org.apache.hello_world.nmr.HelloWorldService; -import org.apache.hello_world.nmr.PingMeFault; -import org.apache.servicemix.cxf.binding.nmr.interceptors.NMROperationInInterceptorTest; -import org.junit.BeforeClass; -import org.junit.Test; - -public class NMRClientServerTest extends AbstractClientServerTestBase { - private final QName serviceName = new QName( - "http://apache.org/hello_world/nmr";, - "HelloWorldService"); - private static final String S1 = - NMROperationInInterceptorTest.class.getResource("/META-INF/cxf/cxf.xml").toString(); - private static final String S2 = - NMROperationInInterceptorTest.class.getClassLoader().getResource("cxf-binding-nmr.xml").toString(); - - @BeforeClass - public static void startServers() throws Exception { - assertTrue("server did not launch correctly", launchServer(Server.class, true)); - } - - - @Test - public void testNMRBinding() throws Exception { - URL wsdl = getClass().getClassLoader().getResource("./hello_world_nmr.wsdl"); - assertNotNull(wsdl); - - TestApplicationContext ctx = new TestApplicationContext(new String[] { - S1, S2 }); - ConfigurerImpl cfg = new ConfigurerImpl(ctx); - Bus bus = (Bus) ctx.getBean(Bus.DEFAULT_BUS_ID); - bus.setExtension(cfg, Configurer.class); - - HelloWorldService ss = new HelloWorldService(wsdl, serviceName); - QName portName = new QName("http://apache.org/hello_world/nmr";, "SoapPort"); - ss.addPort(portName, NMRConstants.NS_NMR_BINDING, "local://nmrendpoint"); - - Greeter port = ss.getPort(portName, Greeter.class); - - String rep = port.greetMe("ffang"); - assertEquals(rep, "Hello ffang"); - rep = port.sayHi(); - assertEquals(rep, "Bonjour"); - try { - port.pingMe(); - fail(); - } catch (PingMeFault ex) { - assertEquals(ex.getFaultInfo().getMajor(), (short)2); - assertEquals(ex.getFaultInfo().getMinor(), (short)1); - } - } -} http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/Server.java ---------------------------------------------------------------------- diff --git a/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/Server.java b/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/Server.java deleted file mode 100644 index 3260faf..0000000 --- a/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/Server.java +++ /dev/null @@ -1,66 +0,0 @@ -/** - * 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.servicemix.cxf.binding.nmr; - -import org.apache.cxf.Bus; -import org.apache.cxf.configuration.Configurer; -import org.apache.cxf.configuration.spring.ConfigurerImpl; -import org.apache.cxf.interceptor.LoggingInInterceptor; -import org.apache.cxf.interceptor.LoggingOutInterceptor; -import org.apache.cxf.jaxws.EndpointImpl; -import org.apache.cxf.test.TestApplicationContext; -import org.apache.cxf.testutil.common.AbstractBusTestServerBase; -import org.apache.servicemix.cxf.binding.nmr.interceptors.NMROperationInInterceptorTest; - -public class Server extends AbstractBusTestServerBase { - private static final String S1 = - NMROperationInInterceptorTest.class.getResource("/META-INF/cxf/cxf.xml").toString(); - private static final String S2 = - NMROperationInInterceptorTest.class.getClassLoader().getResource("cxf-binding-nmr.xml").toString(); - - protected void run() { - TestApplicationContext ctx = new TestApplicationContext(new String[] { - S1, S2 }); - ConfigurerImpl cfg = new ConfigurerImpl(ctx); - Bus bus = (Bus) ctx.getBean(Bus.DEFAULT_BUS_ID); - bus.setExtension(cfg, Configurer.class); - - - Object implementor = new GreeterImpl(); - String address = "local://nmrendpoint"; - //EndpointImpl e = (EndpointImpl)Endpoint.publish(address, implementor); - EndpointImpl e = new EndpointImpl(bus, implementor, NMRConstants.NS_NMR_BINDING); - e.publish(address); - e.getServer().getEndpoint().getInInterceptors().add(new LoggingInInterceptor()); - e.getServer().getEndpoint().getInInterceptors().add(new HackOperationInterceptor()); - e.getServer().getEndpoint().getOutInterceptors().add(new LoggingOutInterceptor()); - } - - public static void main(String args[]) { - try { - Server s = new Server(); - s.start(); - } catch (Exception ex) { - ex.printStackTrace(); - System.exit(-1); - } finally { - System.out.println("done!"); - } - } -} http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/interceptors/NMRFaultOutInterceptorTest.java ---------------------------------------------------------------------- diff --git a/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/interceptors/NMRFaultOutInterceptorTest.java b/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/interceptors/NMRFaultOutInterceptorTest.java deleted file mode 100644 index b9a80c6..0000000 --- a/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/interceptors/NMRFaultOutInterceptorTest.java +++ /dev/null @@ -1,106 +0,0 @@ -/** - * 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.servicemix.cxf.binding.nmr.interceptors; - -import java.io.ByteArrayInputStream; -import java.io.ByteArrayOutputStream; -import java.util.ResourceBundle; - -import javax.xml.stream.XMLOutputFactory; -import javax.xml.stream.XMLStreamWriter; - -import org.w3c.dom.Document; - -import org.apache.cxf.common.i18n.Message; -import org.apache.cxf.helpers.DOMUtils; -import org.apache.cxf.interceptor.Fault; -import org.apache.cxf.message.MessageImpl; -import org.apache.cxf.phase.Phase; -import org.apache.cxf.phase.PhaseInterceptor; -import org.apache.servicemix.cxf.binding.nmr.NMRMessage; -import org.junit.Assert; -import org.junit.Test; - -public class NMRFaultOutInterceptorTest extends Assert { - - @Test - public void testPhase() throws Exception { - PhaseInterceptor<NMRMessage> interceptor = new NMRFaultOutInterceptor(); - assertEquals(Phase.MARSHAL, interceptor.getPhase()); - } - - @Test - public void testNoWriter() throws Exception { - PhaseInterceptor<NMRMessage> interceptor = new NMRFaultOutInterceptor(); - try { - NMRMessage msg = new NMRMessage(new MessageImpl()); - interceptor.handleMessage(msg); - fail("Should have thrown an exception"); - } catch (IllegalStateException e) { - // ok - } - } - - @Test - public void testNoFault() throws Exception { - PhaseInterceptor<NMRMessage> interceptor = new NMRFaultOutInterceptor(); - try { - NMRMessage msg = new NMRMessage(new MessageImpl()); - msg.setContent(XMLStreamWriter.class, - XMLOutputFactory.newInstance().createXMLStreamWriter(new ByteArrayOutputStream())); - interceptor.handleMessage(msg); - fail("Should have thrown an exception"); - } catch (IllegalStateException e) { - // ok - } - } - - @Test - public void testEmptyFault() throws Exception { - PhaseInterceptor<NMRMessage> interceptor = new NMRFaultOutInterceptor(); - ByteArrayOutputStream baos = new ByteArrayOutputStream(); - XMLStreamWriter writer = XMLOutputFactory.newInstance().createXMLStreamWriter(baos); - NMRMessage msg = new NMRMessage(new MessageImpl()); - msg.setContent(XMLStreamWriter.class, writer); - msg.setContent(Exception.class, new Exception("My fault")); - interceptor.handleMessage(msg); - writer.close(); - Document doc = DOMUtils.readXml(new ByteArrayInputStream(baos.toByteArray())); - assertEquals("fault", doc.getDocumentElement().getFirstChild().getNodeName()); - } - - @Test - public void testDetailedFault() throws Exception { - PhaseInterceptor<NMRMessage> interceptor = new NMRFaultOutInterceptor(); - ByteArrayOutputStream baos = new ByteArrayOutputStream(); - XMLStreamWriter writer = XMLOutputFactory.newInstance().createXMLStreamWriter(baos); - NMRMessage msg = new NMRMessage(new MessageImpl()); - Fault f = new Fault(new Message("FAULT", (ResourceBundle) null)); - f.getOrCreateDetail(); - f.getDetail().appendChild(f.getDetail().getOwnerDocument().createElementNS("urn:test", "myDetails")); - msg.setContent(XMLStreamWriter.class, writer); - msg.setContent(Exception.class, f); - interceptor.handleMessage(msg); - writer.close(); - Document doc = DOMUtils.readXml(new ByteArrayInputStream(baos.toByteArray())); - assertEquals("urn:test", doc.getDocumentElement().getFirstChild().getNamespaceURI()); - assertEquals("myDetails", doc.getDocumentElement().getFirstChild().getNodeName()); - } - -} http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/interceptors/NMROperationInInterceptorTest.java ---------------------------------------------------------------------- diff --git a/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/interceptors/NMROperationInInterceptorTest.java b/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/interceptors/NMROperationInInterceptorTest.java deleted file mode 100644 index 7a946a8..0000000 --- a/cxf/cxf-binding-nmr/src/test/java/org/apache/servicemix/cxf/binding/nmr/interceptors/NMROperationInInterceptorTest.java +++ /dev/null @@ -1,99 +0,0 @@ -/** - * 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.servicemix.cxf.binding.nmr.interceptors; - - -import java.util.ResourceBundle; -import java.util.logging.Logger; - -import javax.xml.namespace.QName; - - -import org.apache.cxf.Bus; -import org.apache.cxf.BusFactory; -import org.apache.cxf.binding.BindingFactoryManager; -import org.apache.cxf.common.i18n.Message; -import org.apache.cxf.common.logging.LogUtils; -import org.apache.cxf.configuration.Configurer; -import org.apache.cxf.configuration.spring.ConfigurerImpl; -import org.apache.cxf.endpoint.Endpoint; -import org.apache.cxf.endpoint.EndpointImpl; -import org.apache.cxf.interceptor.Fault; -import org.apache.cxf.message.ExchangeImpl; -import org.apache.cxf.message.MessageImpl; -import org.apache.cxf.phase.Phase; -import org.apache.cxf.phase.PhaseInterceptor; -import org.apache.cxf.service.model.EndpointInfo; -import org.apache.cxf.test.TestApplicationContext; -import org.apache.servicemix.cxf.binding.nmr.NMRBindingInfo; -import org.apache.servicemix.cxf.binding.nmr.NMRConstants; -import org.apache.servicemix.cxf.binding.nmr.NMRMessage; -import org.apache.servicemix.nmr.api.Exchange; -import org.easymock.classextension.EasyMock; -import org.junit.Assert; -import org.junit.Test; - -public class NMROperationInInterceptorTest extends Assert { - - private static final Logger LOG = LogUtils.getL7dLogger(NMROperationInInterceptor.class); - private static final ResourceBundle BUNDLE = LOG.getResourceBundle(); - - private static final String S1 = - NMROperationInInterceptorTest.class.getResource("/META-INF/cxf/cxf.xml").toString(); - private static final String S2 = - NMROperationInInterceptorTest.class.getResource("/META-INF/cxf/binding/nmr/cxf-binding-nmr.xml").toString(); - - @Test - public void testPhase() throws Exception { - PhaseInterceptor<NMRMessage> interceptor = new NMROperationInInterceptor(); - assertEquals(Phase.PRE_PROTOCOL, interceptor.getPhase()); - } - - @Test - public void testUnknownOperation() throws Exception { - PhaseInterceptor<NMRMessage> interceptor = new NMROperationInInterceptor(); - NMRMessage msg = new NMRMessage(new MessageImpl()); - Exchange me = EasyMock.createMock(Exchange.class); - EasyMock.expect(me.getOperation()).andReturn(new QName("urn:test", "SayHi")).times(4); - EasyMock.replay(me); - msg.put(Exchange.class, me); - - TestApplicationContext ctx = new TestApplicationContext(new String[] { - S1, S2 }); - ConfigurerImpl cfg = new ConfigurerImpl(ctx); - Bus bus = (Bus) ctx.getBean(Bus.DEFAULT_BUS_ID); - bus.setExtension(cfg, Configurer.class); - assertNotNull(bus.getExtension(BindingFactoryManager.class).getBindingFactory(NMRConstants.NS_NMR_BINDING)); - - EndpointInfo endpointInfo = new EndpointInfo(); - endpointInfo.setBinding(new NMRBindingInfo(null, NMRConstants.NS_NMR_BINDING)); - Endpoint ep = new EndpointImpl(BusFactory.getDefaultBus(), null, endpointInfo); - msg.setExchange(new ExchangeImpl()); - msg.getExchange().put(Endpoint.class, ep); - try { - interceptor.handleMessage(msg); - fail("shouldn't found SayHi operation"); - } catch (Fault fault) { - assertEquals(fault.getMessage(), new Message("UNKNOWN_OPERATION", BUNDLE, - msg.getNmrExchange().getOperation().toString()).toString()); - } - } - - -} http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/cxf/cxf-binding-nmr/src/test/resources/cxf-binding-nmr.xml ---------------------------------------------------------------------- diff --git a/cxf/cxf-binding-nmr/src/test/resources/cxf-binding-nmr.xml b/cxf/cxf-binding-nmr/src/test/resources/cxf-binding-nmr.xml deleted file mode 100644 index 462e5d8..0000000 --- a/cxf/cxf-binding-nmr/src/test/resources/cxf-binding-nmr.xml +++ /dev/null @@ -1,49 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<!-- - 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. ---> -<beans xmlns="http://www.springframework.org/schema/beans"; - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; - xsi:schemaLocation=" -http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd";> - - <bean class="org.apache.servicemix.cxf.binding.nmr.NMRBindingFactory" - id="org.apache.servicemix.cxf.binding.nmr.NMRBindingFactory" - lazy-init="true"> - <property name="bus" ref="cxf"/> - <property name="activationNamespaces"> - <set> - <value>http://cxf.apache.org/bindings/nmr</value> - <value>http://schemas.xmlsoap.org/wsdl/soap/</value> - <value>http://schemas.xmlsoap.org/wsdl/http/</value> - </set> - </property> - </bean> - <bean class="org.apache.cxf.transport.local.LocalTransportFactory" - id="org.apache.cxf.transport.local.LocalTransportFactory" - lazy-init="true"> - <property name="bus" ref="cxf"/> - <property name="transportIds"> - <list> - <value>http://schemas.xmlsoap.org/wsdl/soap/</value> - <value>http://schemas.xmlsoap.org/wsdl/http/</value> - </list> - </property> - </bean> - -</beans> http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/cxf/cxf-binding-nmr/src/test/resources/hello_world_nmr.wsdl ---------------------------------------------------------------------- diff --git a/cxf/cxf-binding-nmr/src/test/resources/hello_world_nmr.wsdl b/cxf/cxf-binding-nmr/src/test/resources/hello_world_nmr.wsdl deleted file mode 100644 index 3fe5711..0000000 --- a/cxf/cxf-binding-nmr/src/test/resources/hello_world_nmr.wsdl +++ /dev/null @@ -1,165 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<!-- - 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. ---> -<wsdl:definitions name="HelloWorld" targetNamespace="http://apache.org/hello_world/nmr"; - xmlns="http://schemas.xmlsoap.org/wsdl/"; - xmlns:soap="http://schemas.xmlsoap.org/wsdl/soap/"; - xmlns:tns="http://apache.org/hello_world/nmr"; - xmlns:x1="http://apache.org/hello_world/types/nmr"; - xmlns:wsdl="http://schemas.xmlsoap.org/wsdl/"; - xmlns:xsd="http://www.w3.org/2001/XMLSchema"; - xmlns:xformat="http://cxf.apache.org/bindings/xformat"; - xmlns:nmrFormat="http://cxf.apache.org/bindings/nmr";> - - <wsdl:types> - <schema targetNamespace="http://apache.org/hello_world/types/nmr"; - xmlns="http://www.w3.org/2001/XMLSchema"; - xmlns:tns="http://apache.org/hello_world/types/nmr"; - elementFormDefault="qualified"> - <simpleType name="MyStringType"> - <restriction base="string"> - <maxLength value="30" /> - </restriction> - </simpleType> - - <element name="sayHi"> - <complexType/> - </element> - <element name="sayHiResponse"> - <complexType> - <sequence> - <element name="responseType" type="string"/> - </sequence> - </complexType> - </element> - <element name="greetMe"> - <complexType> - <sequence> - <element name="requestType" type="tns:MyStringType"/> - </sequence> - </complexType> - </element> - <element name="greetMeResponse"> - <complexType> - <sequence> - <element name="responseType" type="string"/> - </sequence> - </complexType> - </element> - <element name="greetMeOneWay"> - <complexType> - <sequence> - <element name="requestType" type="string"/> - </sequence> - </complexType> - </element> - <element name="pingMe"> - <complexType/> - </element> - <element name="pingMeResponse"> - <complexType/> - </element> - <element name="faultDetail"> - <complexType> - <sequence> - <element name="minor" type="short"/> - <element name="major" type="short"/> - </sequence> - </complexType> - </element> - </schema> - </wsdl:types> - <wsdl:message name="sayHiRequest"> - <wsdl:part element="x1:sayHi" name="in"/> - </wsdl:message> - <wsdl:message name="sayHiResponse"> - <wsdl:part element="x1:sayHiResponse" name="out"/> - </wsdl:message> - <wsdl:message name="greetMeRequest"> - <wsdl:part element="x1:greetMe" name="in"/> - </wsdl:message> - <wsdl:message name="greetMeResponse"> - <wsdl:part element="x1:greetMeResponse" name="out"/> - </wsdl:message> - <wsdl:message name="greetMeOneWayRequest"> - <wsdl:part element="x1:greetMeOneWay" name="in"/> - </wsdl:message> - <wsdl:message name="pingMeRequest"> - <wsdl:part name="in" element="x1:pingMe"/> - </wsdl:message> - <wsdl:message name="pingMeResponse"> - <wsdl:part name="out" element="x1:pingMeResponse"/> - </wsdl:message> - <wsdl:message name="pingMeFault"> - <wsdl:part name="faultDetail" element="x1:faultDetail"/> - </wsdl:message> - - <wsdl:portType name="Greeter"> - <wsdl:operation name="sayHi"> - <wsdl:input message="tns:sayHiRequest" name="sayHiRequest"/> - <wsdl:output message="tns:sayHiResponse" name="sayHiResponse"/> - </wsdl:operation> - - <wsdl:operation name="greetMe"> - <wsdl:input message="tns:greetMeRequest" name="greetMeRequest"/> - <wsdl:output message="tns:greetMeResponse" name="greetMeResponse"/> - </wsdl:operation> - - <wsdl:operation name="greetMeOneWay"> - <wsdl:input message="tns:greetMeOneWayRequest" name="greetMeOneWayRequest"/> - </wsdl:operation> - - <wsdl:operation name="pingMe"> - <wsdl:input name="pingMeRequest" message="tns:pingMeRequest"/> - <wsdl:output name="pingMeResponse" message="tns:pingMeResponse"/> - <wsdl:fault name="pingMeFault" message="tns:pingMeFault"/> - </wsdl:operation> - </wsdl:portType> - <wsdl:binding name="Greeter_SOAPBinding" type="tns:Greeter"> - <nmrFormat:binding /> - - <wsdl:operation name="sayHi"> - <wsdl:input name="sayHiRequest" /> - <wsdl:output name="sayHiResponse" /> - </wsdl:operation> - - <wsdl:operation name="greetMe"> - <wsdl:input name="greetMeRequest" /> - <wsdl:output name="greetMeResponse" /> - </wsdl:operation> - - <wsdl:operation name="greetMeOneWay"> - <wsdl:input name="greetMeOneWayRequest" /> - </wsdl:operation> - - <wsdl:operation name="pingMe"> - <wsdl:input /> - <wsdl:output /> - <wsdl:fault name="pingMeFault" /> - </wsdl:operation> - - - </wsdl:binding> - <wsdl:service name="HelloWorldService"> - <wsdl:port binding="tns:Greeter_SOAPBinding" name="SoapPort"> - <soap:address location="local://nmrendpoint"/> - </wsdl:port> - </wsdl:service> -</wsdl:definitions> - http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/cxf/cxf-transport-nmr/pom.xml ---------------------------------------------------------------------- diff --git a/cxf/cxf-transport-nmr/pom.xml b/cxf/cxf-transport-nmr/pom.xml deleted file mode 100644 index 94a142d..0000000 --- a/cxf/cxf-transport-nmr/pom.xml +++ /dev/null @@ -1,244 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd";> - - <!-- - - 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. - --> - - <modelVersion>4.0.0</modelVersion> - - <parent> - <groupId>org.apache.servicemix.cxf</groupId> - <artifactId>cxf</artifactId> - <version>4.6.0-SNAPSHOT</version> - </parent> - - <artifactId>org.apache.servicemix.cxf.transport.nmr</artifactId> - <packaging>bundle</packaging> - <name>Apache ServiceMix :: Features :: CXF Support :: Transport For NMR</name> - <description>Apache CXF Transport integration to NMR</description> - - <dependencies> - <dependency> - <groupId>org.apache.servicemix.nmr</groupId> - <artifactId>org.apache.servicemix.nmr.api</artifactId> - </dependency> - <dependency> - <groupId>org.apache.servicemix.nmr</groupId> - <artifactId>org.apache.servicemix.nmr.core</artifactId> - <scope>test</scope> - </dependency> - <dependency> - <groupId>org.apache.cxf</groupId> - <artifactId>cxf-bundle</artifactId> - </dependency> - <dependency> - <groupId>org.apache.geronimo.specs</groupId> - <artifactId>geronimo-ws-metadata_2.0_spec</artifactId> - </dependency> - <dependency> - <groupId>org.apache.geronimo.specs</groupId> - <artifactId>geronimo-annotation_1.0_spec</artifactId> - </dependency> - <dependency> - <groupId>org.apache.geronimo.specs</groupId> - <artifactId>geronimo-servlet_2.5_spec</artifactId> - </dependency> - <dependency> - <groupId>org.apache.servicemix.specs</groupId> - <artifactId>org.apache.servicemix.specs.jaxb-api-${jaxb.api.version}</artifactId> - </dependency> - <dependency> - <groupId>junit</groupId> - <artifactId>junit</artifactId> - <scope>test</scope> - </dependency> - <dependency> - <groupId>org.easymock</groupId> - <artifactId>easymockclassextension</artifactId> - <scope>test</scope> - </dependency> - </dependencies> - - <build> - <plugins> - <!-- Bundle generation --> - <plugin> - <groupId>org.apache.felix</groupId> - <artifactId>maven-bundle-plugin</artifactId> - <configuration> - <instructions> - <Bundle-SymbolicName>${project.artifactId}</Bundle-SymbolicName> - <Bundle-Description>${project.description}</Bundle-Description> - <Import-Package> - javax.xml.bind*;version="[0.0,3)", - javax.activation;version="[0.0,2)", - javax.annotation;version="[0.0,2)", - javax.jws*;version="[0.0,3)", - * - </Import-Package> - <!-- Needed for jaxb annotations classes --> - <DynamicImport-Package>*</DynamicImport-Package> - <Export-Package> - ${project.artifactId}*, - org.apache.cxf.transports.nmr, - '=META-INF.cxf.transport.nmr' - </Export-Package> - <Private-Package /> - <_failok>true</_failok> - <Spring-Context>*;publish-context:=false</Spring-Context> - <_versionpolicy>[$(version;==;$(@)),$(version;+;$(@)))</_versionpolicy> - </instructions> - </configuration> - </plugin> - <!-- generate dependencies versions --> - <plugin> - <groupId>org.apache.servicemix.tooling</groupId> - <artifactId>depends-maven-plugin</artifactId> - <executions> - <execution> - <id>generate-depends-file</id> - <goals> - <goal>generate-depends-file</goal> - </goals> - </execution> - </executions> - </plugin> - <plugin> - <groupId>org.apache.maven.plugins</groupId> - <artifactId>maven-surefire-plugin</artifactId> - <configuration> - <forkMode>pertest</forkMode> - <systemProperties> - <property> - <name>javax.xml.parsers.DocumentBuilderFactory</name> - <value>com.sun.org.apache.xerces.internal.jaxp.DocumentBuilderFactoryImpl</value> - </property> - <property> - <name>javax.xml.datatype.DatatypeFactory</name> - <value>com.sun.org.apache.xerces.internal.jaxp.datatype.DatatypeFactoryImpl</value> - </property> - <property> - <name>javax.xml.parsers.SAXParserFactory</name> - <value>com.sun.org.apache.xerces.internal.jaxp.SAXParserFactoryImpl</value> - </property> - </systemProperties> - </configuration> - </plugin> - <plugin> - <groupId>org.apache.cxf</groupId> - <artifactId>cxf-xjc-plugin</artifactId> - <version>${cxf.xjc-utils.version}</version> - <executions> - <execution> - <id>generate-sources</id> - <phase>generate-sources</phase> - <configuration> - <sourceRoot>${basedir}/target/generated/src/main/java</sourceRoot> - <xsdOptions> - <xsdOption> - <xsd>${basedir}/src/main/resources/schemas/wsdl/nmr.xsd</xsd> - <bindingFile>${basedir}/src/main/resources/schemas/wsdl/nmr.xjb</bindingFile> - <catalog>${basedir}/src/main/build-resources/catalog.cat</catalog> - <deleteDirs> - <deleteDir>${basedir}/target/generated/src/main/java/org/apache/cxf/wsdl</deleteDir> - </deleteDirs> - </xsdOption> - - </xsdOptions> - </configuration> - <goals> - <goal>xsdtojava</goal> - </goals> - </execution> - </executions> - </plugin> - <!-- exclude generated class from Cobertura reports --> - <plugin> - <groupId>org.codehaus.mojo</groupId> - <artifactId>cobertura-maven-plugin</artifactId> - <configuration> - <instrumentation> - <excludes> - <exclude>org/apache/servicemix/cxf/transport/nmr/ObjectFactory.class</exclude> - <exclude>org/apache/servicemix/cxf/transport/nmr/package-info.class</exclude> - <exclude>org/apache/servicemix/cxf/transport/nmr/AddressType.class</exclude> - </excludes> - </instrumentation> - </configuration> - </plugin> - </plugins> - </build> - - <profiles> - <profile> - <id>ibmjdk</id> - <activation> - <property> - <name>java.vendor</name> - <value>IBM Corporation</value> - </property> - </activation> - <!-- Add the Sun jaxp-ri as a dependency when using the ibm jdk, so that - cxf's dependency on the Sun saaj can work with the ibm jdk. --> - <dependencies> - <dependency> - <groupId>com.sun.xml.parsers</groupId> - <artifactId>jaxp-ri</artifactId> - </dependency> - </dependencies> - <build> - <plugins> - <plugin> - <groupId>org.apache.maven.plugins</groupId> - <artifactId>maven-surefire-plugin</artifactId> - <configuration> - <includes> - <include>**/*Test*</include> - </includes> - <excludes> - <exclude>**/*$*</exclude> - </excludes> - <forkMode>${surefire.fork.mode}</forkMode> - <systemProperties> - <property> - <name>derby.system.home</name> - <value>${basedir}/target/derby</value> - </property> - <!-- With Maven 2.0.7, it's possible that jaxp-ri will be placed - in front of woodstox on the classpath. If this happens, cxf will not use - woodstox, causing test failures (e.g., CxfBcProviderConsumerMtomTest). So, - set these properties to ensure woodstox is used. Maven 2.0.9 doesn't require - this work-around since it consistently places jaxp-ri at the end of the dependencies. --> - <property> - <name>javax.xml.stream.XMLInputFactory</name> - <value>com.ctc.wstx.stax.WstxInputFactory</value> - </property> - <property> - <name>javax.xml.stream.XMLOutputFactory</name> - <value>com.ctc.wstx.stax.WstxOutputFactory</value> - </property> - </systemProperties> - </configuration> - </plugin> - - </plugins> - </build> - </profile> - </profiles> - -</project> http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/cxf/cxf-transport-nmr/src/main/build-resources/catalog.cat ---------------------------------------------------------------------- diff --git a/cxf/cxf-transport-nmr/src/main/build-resources/catalog.cat b/cxf/cxf-transport-nmr/src/main/build-resources/catalog.cat deleted file mode 100644 index f7f735b..0000000 --- a/cxf/cxf-transport-nmr/src/main/build-resources/catalog.cat +++ /dev/null @@ -1,21 +0,0 @@ --- - 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. --- - -SYSTEM "http://schemas.xmlsoap.org/wsdl/2003-02-11.xsd"; "wsdl.xsd" -SYSTEM "http://schemas.xmlsoap.org/wsdl/"; "wsdl.xsd" http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/cxf/cxf-transport-nmr/src/main/build-resources/wsdl.xsd ---------------------------------------------------------------------- diff --git a/cxf/cxf-transport-nmr/src/main/build-resources/wsdl.xsd b/cxf/cxf-transport-nmr/src/main/build-resources/wsdl.xsd deleted file mode 100644 index 67dfd67..0000000 --- a/cxf/cxf-transport-nmr/src/main/build-resources/wsdl.xsd +++ /dev/null @@ -1,310 +0,0 @@ -<?xml version="1.0" encoding="UTF-8" ?> -<!-- - -Copyright 2001 - 2005, International Business Machines Corporation and Microsoft Corporation -All Rights Reserved - -License for WSDL Schema Files - -The Authors grant permission to copy and distribute the WSDL Schema -Files in any medium without fee or royalty as long as this notice and -license are distributed with them. The originals of these files can -be located at: - -http://schemas.xmlsoap.org/wsdl/2003-02-11.xsd - -THESE SCHEMA FILES ARE PROVIDED "AS IS," AND THE AUTHORS MAKE NO REPRESENTATIONS -OR WARRANTIES, EXPRESS OR IMPLIED, REGARDING THESE FILES, INCLUDING, BUT NOT -LIMITED TO, WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE, -NON-INFRINGEMENT OR TITLE. THE AUTHORS WILL NOT BE LIABLE FOR ANY DIRECT, -INDIRECT, SPECIAL, INCIDENTAL OR CONSEQUENTIAL DAMAGES ARISING OUT OF OR -RELATING TO ANY USE OR DISTRIBUTION OF THESE FILES. - -The name and trademarks of the Authors may NOT be used in any manner, -including advertising or publicity pertaining to these files or any program -or service that uses these files, written prior permission. Title to copyright -in these files will at all times remain with the Authors. - -No other rights are granted by implication, estoppel or otherwise. - - ---> -<xs:schema xmlns:xs="http://www.w3.org/2001/XMLSchema"; - xmlns:wsdl="http://schemas.xmlsoap.org/wsdl/"; - targetNamespace="http://schemas.xmlsoap.org/wsdl/"; - elementFormDefault="qualified" > - - <xs:complexType mixed="true" name="tDocumentation" > - <xs:sequence> - <xs:any minOccurs="0" maxOccurs="unbounded" processContents="lax" /> - </xs:sequence> - </xs:complexType> - - <xs:complexType name="tDocumented" > - <xs:annotation> - <xs:documentation> - This type is extended by component types to allow them to be documented - </xs:documentation> - </xs:annotation> - <xs:sequence> - <xs:element name="documentation" type="wsdl:tDocumentation" minOccurs="0" /> - </xs:sequence> - </xs:complexType> - - <xs:complexType name="tExtensibleAttributesDocumented" abstract="true" > - <xs:complexContent> - <xs:extension base="wsdl:tDocumented" > - <xs:annotation> - <xs:documentation> - This type is extended by component types to allow attributes from other namespaces to be added. - </xs:documentation> - </xs:annotation> - <xs:anyAttribute namespace="##other" processContents="lax" /> - </xs:extension> - </xs:complexContent> - </xs:complexType> - - <xs:complexType name="tExtensibleDocumented" abstract="true" > - <xs:complexContent> - <xs:extension base="wsdl:tDocumented" > - <xs:annotation> - <xs:documentation> - This type is extended by component types to allow elements from other namespaces to be added. - </xs:documentation> - </xs:annotation> - <xs:sequence> - <xs:any namespace="##other" minOccurs="0" maxOccurs="unbounded" processContents="lax" /> - </xs:sequence> - </xs:extension> - </xs:complexContent> - </xs:complexType> - - <xs:element name="definitions" type="wsdl:tDefinitions" > - <xs:key name="message" > - <xs:selector xpath="wsdl:message" /> - <xs:field xpath="@name" /> - </xs:key> - <xs:key name="portType" > - <xs:selector xpath="wsdl:portType" /> - <xs:field xpath="@name" /> - </xs:key> - <xs:key name="binding" > - <xs:selector xpath="wsdl:binding" /> - <xs:field xpath="@name" /> - </xs:key> - <xs:key name="service" > - <xs:selector xpath="wsdl:service" /> - <xs:field xpath="@name" /> - </xs:key> - <xs:key name="import" > - <xs:selector xpath="wsdl:import" /> - <xs:field xpath="@namespace" /> - </xs:key> - </xs:element> - - <xs:group name="anyTopLevelOptionalElement" > - <xs:annotation> - <xs:documentation> - Any top level optional element allowed to appear more then once - any child of definitions element except wsdl:types. Any extensibility element is allowed in any place. - </xs:documentation> - </xs:annotation> - <xs:choice> - <xs:element name="import" type="wsdl:tImport" /> - <xs:element name="types" type="wsdl:tTypes" /> - <xs:element name="message" type="wsdl:tMessage" > - <xs:unique name="part" > - <xs:selector xpath="wsdl:part" /> - <xs:field xpath="@name" /> - </xs:unique> - </xs:element> - <xs:element name="portType" type="wsdl:tPortType" /> - <xs:element name="binding" type="wsdl:tBinding" /> - <xs:element name="service" type="wsdl:tService" > - <xs:unique name="port" > - <xs:selector xpath="wsdl:port" /> - <xs:field xpath="@name" /> - </xs:unique> - </xs:element> - </xs:choice> - </xs:group> - - <xs:complexType name="tDefinitions" > - <xs:complexContent> - <xs:extension base="wsdl:tExtensibleDocumented" > - <xs:sequence> - <xs:group ref="wsdl:anyTopLevelOptionalElement" minOccurs="0" maxOccurs="unbounded" /> - </xs:sequence> - <xs:attribute name="targetNamespace" type="xs:anyURI" use="optional" /> - <xs:attribute name="name" type="xs:NCName" use="optional" /> - </xs:extension> - </xs:complexContent> - </xs:complexType> - - <xs:complexType name="tImport" > - <xs:complexContent> - <xs:extension base="wsdl:tExtensibleAttributesDocumented" > - <xs:attribute name="namespace" type="xs:anyURI" use="required" /> - <xs:attribute name="location" type="xs:anyURI" use="required" /> - </xs:extension> - </xs:complexContent> - </xs:complexType> - - <xs:complexType name="tTypes" > - <xs:complexContent> - <xs:extension base="wsdl:tExtensibleDocumented" /> - </xs:complexContent> - </xs:complexType> - - <xs:complexType name="tMessage" > - <xs:complexContent> - <xs:extension base="wsdl:tExtensibleDocumented" > - <xs:sequence> - <xs:element name="part" type="wsdl:tPart" minOccurs="0" maxOccurs="unbounded" /> - </xs:sequence> - <xs:attribute name="name" type="xs:NCName" use="required" /> - </xs:extension> - </xs:complexContent> - </xs:complexType> - - <xs:complexType name="tPart" > - <xs:complexContent> - <xs:extension base="wsdl:tExtensibleAttributesDocumented" > - <xs:attribute name="name" type="xs:NCName" use="required" /> - <xs:attribute name="element" type="xs:QName" use="optional" /> - <xs:attribute name="type" type="xs:QName" use="optional" /> - </xs:extension> - </xs:complexContent> - </xs:complexType> - - <xs:complexType name="tPortType" > - <xs:complexContent> - <xs:extension base="wsdl:tExtensibleAttributesDocumented" > - <xs:sequence> - <xs:element name="operation" type="wsdl:tOperation" minOccurs="0" maxOccurs="unbounded" /> - </xs:sequence> - <xs:attribute name="name" type="xs:NCName" use="required" /> - </xs:extension> - </xs:complexContent> - </xs:complexType> - - <xs:complexType name="tOperation" > - <xs:complexContent> - <xs:extension base="wsdl:tExtensibleDocumented" > - <xs:sequence> - <xs:choice> - <xs:group ref="wsdl:request-response-or-one-way-operation" /> - <xs:group ref="wsdl:solicit-response-or-notification-operation" /> - </xs:choice> - </xs:sequence> - <xs:attribute name="name" type="xs:NCName" use="required" /> - <xs:attribute name="parameterOrder" type="xs:NMTOKENS" use="optional" /> - </xs:extension> - </xs:complexContent> - </xs:complexType> - - <xs:group name="request-response-or-one-way-operation" > - <xs:sequence> - <xs:element name="input" type="wsdl:tParam" /> - <xs:sequence minOccurs='0' > - <xs:element name="output" type="wsdl:tParam" /> - <xs:element name="fault" type="wsdl:tFault" minOccurs="0" maxOccurs="unbounded" /> - </xs:sequence> - </xs:sequence> - </xs:group> - - <xs:group name="solicit-response-or-notification-operation" > - <xs:sequence> - <xs:element name="output" type="wsdl:tParam" /> - <xs:sequence minOccurs='0' > - <xs:element name="input" type="wsdl:tParam" /> - <xs:element name="fault" type="wsdl:tFault" minOccurs="0" maxOccurs="unbounded" /> - </xs:sequence> - </xs:sequence> - </xs:group> - - <xs:complexType name="tParam" > - <xs:complexContent> - <xs:extension base="wsdl:tExtensibleAttributesDocumented" > - <xs:attribute name="name" type="xs:NCName" use="optional" /> - <xs:attribute name="message" type="xs:QName" use="required" /> - </xs:extension> - </xs:complexContent> - </xs:complexType> - - <xs:complexType name="tFault" > - <xs:complexContent> - <xs:extension base="wsdl:tExtensibleAttributesDocumented" > - <xs:attribute name="name" type="xs:NCName" use="required" /> - <xs:attribute name="message" type="xs:QName" use="required" /> - </xs:extension> - </xs:complexContent> - </xs:complexType> - - <xs:complexType name="tBinding" > - <xs:complexContent> - <xs:extension base="wsdl:tExtensibleDocumented" > - <xs:sequence> - <xs:element name="operation" type="wsdl:tBindingOperation" minOccurs="0" maxOccurs="unbounded" /> - </xs:sequence> - <xs:attribute name="name" type="xs:NCName" use="required" /> - <xs:attribute name="type" type="xs:QName" use="required" /> - </xs:extension> - </xs:complexContent> - </xs:complexType> - - <xs:complexType name="tBindingOperationMessage" > - <xs:complexContent> - <xs:extension base="wsdl:tExtensibleDocumented" > - <xs:attribute name="name" type="xs:NCName" use="optional" /> - </xs:extension> - </xs:complexContent> - </xs:complexType> - - <xs:complexType name="tBindingOperationFault" > - <xs:complexContent> - <xs:extension base="wsdl:tExtensibleDocumented" > - <xs:attribute name="name" type="xs:NCName" use="required" /> - </xs:extension> - </xs:complexContent> - </xs:complexType> - - <xs:complexType name="tBindingOperation" > - <xs:complexContent> - <xs:extension base="wsdl:tExtensibleDocumented" > - <xs:sequence> - <xs:element name="input" type="wsdl:tBindingOperationMessage" minOccurs="0" /> - <xs:element name="output" type="wsdl:tBindingOperationMessage" minOccurs="0" /> - <xs:element name="fault" type="wsdl:tBindingOperationFault" minOccurs="0" maxOccurs="unbounded" /> - </xs:sequence> - <xs:attribute name="name" type="xs:NCName" use="required" /> - </xs:extension> - </xs:complexContent> - </xs:complexType> - - <xs:complexType name="tService" > - <xs:complexContent> - <xs:extension base="wsdl:tExtensibleDocumented" > - <xs:sequence> - <xs:element name="port" type="wsdl:tPort" minOccurs="0" maxOccurs="unbounded" /> - </xs:sequence> - <xs:attribute name="name" type="xs:NCName" use="required" /> - </xs:extension> - </xs:complexContent> - </xs:complexType> - - <xs:complexType name="tPort" > - <xs:complexContent> - <xs:extension base="wsdl:tExtensibleDocumented" > - <xs:attribute name="name" type="xs:NCName" use="required" /> - <xs:attribute name="binding" type="xs:QName" use="required" /> - </xs:extension> - </xs:complexContent> - </xs:complexType> - - <xs:attribute name="arrayType" type="xs:string" /> - <xs:attribute name="required" type="xs:boolean" /> - <xs:complexType name="tExtensibilityElement" abstract="true" > - <xs:attribute ref="wsdl:required" use="optional" /> - </xs:complexType> - -</xs:schema> http://git-wip-us.apache.org/repos/asf/servicemix-features/blob/d358d2ea/cxf/cxf-transport-nmr/src/main/java/org/apache/servicemix/cxf/transport/nmr/NMRConduit.java ---------------------------------------------------------------------- diff --git a/cxf/cxf-transport-nmr/src/main/java/org/apache/servicemix/cxf/transport/nmr/NMRConduit.java b/cxf/cxf-transport-nmr/src/main/java/org/apache/servicemix/cxf/transport/nmr/NMRConduit.java deleted file mode 100644 index 1162d8e..0000000 --- a/cxf/cxf-transport-nmr/src/main/java/org/apache/servicemix/cxf/transport/nmr/NMRConduit.java +++ /dev/null @@ -1,73 +0,0 @@ -/** - * 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.servicemix.cxf.transport.nmr; - -import java.io.IOException; -import java.io.OutputStream; -import java.util.logging.Level; -import java.util.logging.Logger; - -import org.apache.cxf.Bus; -import org.apache.cxf.common.logging.LogUtils; -import org.apache.cxf.message.Message; -import org.apache.cxf.transport.AbstractConduit; -import org.apache.cxf.ws.addressing.EndpointReferenceType; -import org.apache.servicemix.nmr.api.NMR; - - -public class NMRConduit extends AbstractConduit { - - private static final Logger LOG = LogUtils.getL7dLogger(NMRConduit.class); - - private NMR nmr; - private Bus bus; - - public NMRConduit(EndpointReferenceType target, NMR nmr) { - this(null, target, nmr); - } - - public NMRConduit(Bus bus, EndpointReferenceType target, NMR nmr) { - super(target); - this.nmr = nmr; - this.bus = bus; - } - - public Bus getBus() { - return bus; - } - - public NMR getNmr() { - return nmr; - } - - protected Logger getLogger() { - return LOG; - } - - public void prepare(Message message) throws IOException { - getLogger().log(Level.FINE, "JBIConduit send message"); - NMRTransportFactory.removeUnusedInterceptprs(message); - message.setContent(OutputStream.class, - new NMRConduitOutputStream(message, nmr, target, this)); - } - - - -}
