cxf-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From r...@apache.org
Subject [36/50] [abbrv] cxf git commit: Squash commit of ws-transfer implementation from Erich Duda (dudaerich) This closes #33
Date Thu, 26 May 2016 21:46:04 GMT
Squash commit of ws-transfer implementation from Erich Duda (dudaerich)
This closes #33


Project: http://git-wip-us.apache.org/repos/asf/cxf/repo
Commit: http://git-wip-us.apache.org/repos/asf/cxf/commit/517ef67f
Tree: http://git-wip-us.apache.org/repos/asf/cxf/tree/517ef67f
Diff: http://git-wip-us.apache.org/repos/asf/cxf/diff/517ef67f

Branch: refs/heads/master-jaxrs-2.1
Commit: 517ef67f1a69d386de44153e5e09d51cb47bf4d7
Parents: e158c96
Author: Daniel Kulp <dkulp@apache.org>
Authored: Tue May 24 09:26:41 2016 -0400
Committer: Daniel Kulp <dkulp@apache.org>
Committed: Tue May 24 09:26:41 2016 -0400

----------------------------------------------------------------------
 rt/ws/pom.xml                                   |   1 +
 rt/ws/transfer/pom.xml                          |  91 +++
 .../apache/cxf/ws/transfer/dialect/Dialect.java |  64 ++
 .../dialect/fragment/FragmentDialect.java       | 622 +++++++++++++++++++
 .../fragment/FragmentDialectConstants.java      |  51 ++
 .../dialect/fragment/faults/FragmentFault.java  |  44 ++
 .../fragment/faults/InvalidExpression.java      |  42 ++
 .../fragment/faults/UnsupportedLanguage.java    |  41 ++
 .../fragment/faults/UnsupportedMode.java        |  42 ++
 .../language/FragmentDialectLanguage.java       |  37 ++
 .../language/FragmentDialectLanguageQName.java  | 134 ++++
 .../FragmentDialectLanguageXPath10.java         | 160 +++++
 .../transfer/manager/MemoryResourceManager.java | 160 +++++
 .../ws/transfer/manager/ResourceManager.java    |  59 ++
 .../cxf/ws/transfer/resource/Resource.java      | 101 +++
 .../cxf/ws/transfer/resource/ResourceLocal.java | 191 ++++++
 .../ws/transfer/resource/ResourceRemote.java    |  49 ++
 .../resourcefactory/ResourceFactory.java        |  61 ++
 .../resourcefactory/ResourceFactoryImpl.java    | 153 +++++
 .../resolver/ResourceReference.java             |  61 ++
 .../resolver/ResourceResolver.java              |  39 ++
 .../resolver/SimpleResourceResolver.java        |  69 ++
 .../ws/transfer/shared/TransferConstants.java   |  60 ++
 .../shared/faults/InvalidRepresentation.java    |  41 ++
 .../ws/transfer/shared/faults/PutDenied.java    |  44 ++
 .../transfer/shared/faults/UnknownDialect.java  |  43 ++
 .../transfer/shared/faults/UnknownResource.java |  42 ++
 .../transfer/shared/faults/WSTransferFault.java |  45 ++
 .../ResourceTransformer.java                    |  30 +
 .../ResourceTypeIdentifier.java                 |  36 ++
 .../ResourceTypeIdentifierResult.java           |  56 ++
 .../ResourceValidator.java                      |  31 +
 .../ValidAndTransformHelper.java                |  63 ++
 .../XSDResourceTypeIdentifier.java              |  87 +++
 .../XSDResourceValidator.java                   |  88 +++
 .../XSLTResourceTransformer.java                |  87 +++
 .../reference-parameter-parsing.xml             |  27 +
 .../main/resources/schemas/catalog-fragment.cat |  21 +
 .../src/main/resources/schemas/catalog.cat      |  23 +
 .../src/main/resources/schemas/fragment.xsd     |  87 +++
 .../src/main/resources/schemas/transfer.xjb     |  37 ++
 .../src/main/resources/schemas/transfer.xsd     | 192 ++++++
 .../src/main/resources/schemas/ws-addr.xsd      | 141 +++++
 .../integration/FragmentGetQNameTest.java       | 171 +++++
 .../integration/FragmentGetXPath10Test.java     | 333 ++++++++++
 .../integration/FragmentPutAddTest.java         | 238 +++++++
 .../integration/FragmentPutInsertAfterTest.java | 194 ++++++
 .../FragmentPutInsertBeforeTest.java            | 194 ++++++
 .../integration/FragmentPutRemoveTest.java      | 113 ++++
 .../integration/FragmentPutReplaceTest.java     | 419 +++++++++++++
 .../integration/IntegrationBaseTest.java        | 196 ++++++
 .../integration/ResourceFactoryTest.java        | 135 ++++
 .../ws/transfer/integration/ResourceTest.java   | 168 +++++
 .../unit/MemoryResourceManagerTest.java         | 204 ++++++
 .../transfer/unit/XSDResourceValidatorTest.java |  60 ++
 .../unit/XSLTResourceTransformerTest.java       |  60 ++
 .../invalidRepresentation.xml                   |  26 +
 .../xml/xsdresourcevalidator/schema.xsd         |  35 ++
 .../validRepresentation.xml                     |  27 +
 .../xsltresourcetransformer/representation.xml  |  26 +
 .../xml/xsltresourcetransformer/stylesheet.xsl  |  43 ++
 systests/pom.xml                                |   3 +-
 systests/ws-transfer/pom.xml                    |  61 ++
 .../systest/ws/transfer/CreateStudentTest.java  | 103 +++
 .../systest/ws/transfer/CreateTeacherTest.java  |  91 +++
 .../cxf/systest/ws/transfer/DeleteTest.java     | 118 ++++
 .../apache/cxf/systest/ws/transfer/GetTest.java | 111 ++++
 .../apache/cxf/systest/ws/transfer/PutTest.java | 129 ++++
 .../cxf/systest/ws/transfer/TestUtils.java      | 174 ++++++
 .../cxf/systest/ws/transfer/UIDManager.java     |  40 ++
 .../transfer/resolver/MyResourceResolver.java   |  55 ++
 .../validator/StudentPutResourceValidator.java  |  47 ++
 .../validator/TeacherResourceValidator.java     |  51 ++
 .../src/test/resources/schema/studentCreate.xsd |  46 ++
 .../src/test/resources/schema/studentPut.xsd    |  47 ++
 .../src/test/resources/schema/teacher.xsd       |  47 ++
 .../resources/schema/teacherCreateBasic.xsd     |  35 ++
 .../src/test/resources/xml/createStudent.xml    |  31 +
 .../test/resources/xml/createStudentPartial.xml |  29 +
 .../test/resources/xml/createStudentWrong.xml   |  32 +
 .../src/test/resources/xml/createTeacher.xml    |  31 +
 .../test/resources/xml/createTeacherPartial.xml |  25 +
 .../test/resources/xml/createTeacherWrong.xml   |  32 +
 .../src/test/resources/xml/putStudent.xml       |  32 +
 .../src/test/resources/xml/putTeacher.xml       |  32 +
 .../src/test/resources/xml/random.xml           |  24 +
 .../src/test/resources/xslt/studentCreate.xsl   | 110 ++++
 .../src/test/resources/xslt/studentPut.xsl      | 108 ++++
 .../test/resources/xslt/teacherCreateBasic.xsl  |  45 ++
 .../resources/xslt/teacherDefaultValues.xsl     | 108 ++++
 90 files changed, 7991 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cxf/blob/517ef67f/rt/ws/pom.xml
----------------------------------------------------------------------
diff --git a/rt/ws/pom.xml b/rt/ws/pom.xml
index 0bea25c..70e1c97 100644
--- a/rt/ws/pom.xml
+++ b/rt/ws/pom.xml
@@ -36,5 +36,6 @@
         <module>rm</module>
         <module>mex</module>
         <module>eventing</module>
+        <module>transfer</module>
     </modules>
 </project>

http://git-wip-us.apache.org/repos/asf/cxf/blob/517ef67f/rt/ws/transfer/pom.xml
----------------------------------------------------------------------
diff --git a/rt/ws/transfer/pom.xml b/rt/ws/transfer/pom.xml
new file mode 100644
index 0000000..d2c1a09
--- /dev/null
+++ b/rt/ws/transfer/pom.xml
@@ -0,0 +1,91 @@
+<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/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+
+  <artifactId>cxf-rt-ws-transfer</artifactId>
+  <packaging>jar</packaging>
+  <name>Apache CXF Runtime WS Transfer</name>
+  <url>http://cxf.apache.org</url>
+  
+  <parent>
+      <groupId>org.apache.cxf</groupId>
+      <artifactId>cxf-parent</artifactId>
+      <version>3.2.0-SNAPSHOT</version>
+      <relativePath>../../../parent/pom.xml</relativePath>
+  </parent>
+
+  <properties>
+    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+  </properties>
+
+  <dependencies>
+    <dependency>
+      <groupId>${project.groupId}</groupId>
+      <artifactId>cxf-rt-frontend-jaxws</artifactId>
+      <version>${project.version}</version>
+    </dependency>
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>${project.groupId}</groupId>
+      <artifactId>cxf-rt-transports-local</artifactId>
+      <version>${project.version}</version>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.easymock</groupId>
+      <artifactId>easymock</artifactId>
+      <scope>test</scope>
+    </dependency>
+  </dependencies>
+  
+  <build>
+      <plugins>
+          <plugin>
+              <groupId>org.apache.cxf</groupId>
+              <artifactId>cxf-xjc-plugin</artifactId>
+              <version>${cxf.xjc-utils.version}</version>
+              <executions>
+                  <execution>
+                      <id>generate-transfer</id>
+                      <phase>generate-sources</phase>
+                      <goals>
+                          <goal>xsdtojava</goal>
+                      </goals>
+                      <configuration>
+                          <sourceRoot>${basedir}/target/generated-sources/xjc</sourceRoot>
+                          <xsdOptions>
+                              <xsdOption>
+                                  <xsd>${basedir}/src/main/resources/schemas/transfer.xsd</xsd>
+                                  <packagename>org.apache.cxf.ws.transfer</packagename>
+                                  <bindingFile>${basedir}/src/main/resources/schemas/transfer.xjb</bindingFile>
+                                  <catalog>${basedir}/src/main/resources/schemas/catalog.cat</catalog>
+                              </xsdOption>
+                          </xsdOptions>
+                      </configuration>
+                  </execution>
+                  <execution>
+                      <id>generate-fragment</id>
+                      <phase>generate-sources</phase>
+                      <goals>
+                          <goal>xsdtojava</goal>
+                      </goals>
+                      <configuration>
+                          <sourceRoot>${basedir}/target/generated-sources/xjc</sourceRoot>
+                          <xsdOptions>
+                              <xsdOption>
+                                  <xsd>${basedir}/src/main/resources/schemas/fragment.xsd</xsd>
+                                  <packagename>org.apache.cxf.ws.transfer.dialect.fragment</packagename>
+                                  <catalog>${basedir}/src/main/resources/schemas/catalog-fragment.cat</catalog>
+                              </xsdOption>
+                          </xsdOptions>
+                      </configuration>
+                  </execution>
+              </executions>
+          </plugin>
+      </plugins>
+  </build>
+</project>

http://git-wip-us.apache.org/repos/asf/cxf/blob/517ef67f/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/Dialect.java
----------------------------------------------------------------------
diff --git a/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/Dialect.java b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/Dialect.java
new file mode 100644
index 0000000..6ea5208
--- /dev/null
+++ b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/Dialect.java
@@ -0,0 +1,64 @@
+/**
+ * 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.cxf.ws.transfer.dialect;
+
+import org.apache.cxf.ws.transfer.Create;
+import org.apache.cxf.ws.transfer.Delete;
+import org.apache.cxf.ws.transfer.Get;
+import org.apache.cxf.ws.transfer.Put;
+import org.apache.cxf.ws.transfer.Representation;
+
+/**
+ * The interface for a Dialect objects.
+ */
+public interface Dialect {
+    
+    /**
+     * Method for processing incoming Get message by Dialect extension.
+     * @param body Get body
+     * @param representation XML representation stored in the ResourceManager
+     * @return Representation, which will be returned in response.
+     */
+    Object processGet(Get body, Representation representation);
+    
+    /**
+     * Method for processing incoming Put message by Dialect extension.
+     * @param body Put body
+     * @param representation XML representation stored in the ResourceManager
+     * @return Representation, which will be stored in ResourceManager.
+     */
+    Representation processPut(Put body, Representation representation);
+    
+    /**
+     * Method for processing incoming Delete message by Dialect extension.
+     * @param body Delete body
+     * @param representation XML representation stored in the ResourceManager
+     * @return Representation, which will be stored in ResourceManager.
+     */
+    boolean processDelete(Delete body, Representation representation);
+    
+    /**
+     * Method for processing incoming Create message by Dialect extension.
+     * @param body Create body
+     * @return Representation, which will be stored in ResourceManager.
+     */
+    Representation processCreate(Create body);
+    
+}

http://git-wip-us.apache.org/repos/asf/cxf/blob/517ef67f/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/FragmentDialect.java
----------------------------------------------------------------------
diff --git a/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/FragmentDialect.java b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/FragmentDialect.java
new file mode 100644
index 0000000..8498ff8
--- /dev/null
+++ b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/FragmentDialect.java
@@ -0,0 +1,622 @@
+/**
+ * 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.cxf.ws.transfer.dialect.fragment;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.regex.Pattern;
+
+import javax.annotation.Resource;
+import javax.xml.bind.JAXBElement;
+import javax.xml.ws.WebServiceContext;
+import org.w3c.dom.Attr;
+import org.w3c.dom.Document;
+import org.w3c.dom.Element;
+import org.w3c.dom.Node;
+import org.w3c.dom.NodeList;
+import org.apache.cxf.binding.soap.SoapFault;
+import org.apache.cxf.binding.soap.SoapMessage;
+import org.apache.cxf.binding.soap.SoapVersion;
+import org.apache.cxf.helpers.DOMUtils;
+import org.apache.cxf.jaxws.context.WrappedMessageContext;
+import org.apache.cxf.ws.transfer.Create;
+import org.apache.cxf.ws.transfer.Delete;
+import org.apache.cxf.ws.transfer.Get;
+import org.apache.cxf.ws.transfer.Put;
+import org.apache.cxf.ws.transfer.Representation;
+import org.apache.cxf.ws.transfer.dialect.Dialect;
+import org.apache.cxf.ws.transfer.dialect.fragment.faults.InvalidExpression;
+import org.apache.cxf.ws.transfer.dialect.fragment.faults.UnsupportedLanguage;
+import org.apache.cxf.ws.transfer.dialect.fragment.faults.UnsupportedMode;
+import org.apache.cxf.ws.transfer.dialect.fragment.language.FragmentDialectLanguage;
+import org.apache.cxf.ws.transfer.dialect.fragment.language.FragmentDialectLanguageQName;
+import org.apache.cxf.ws.transfer.dialect.fragment.language.FragmentDialectLanguageXPath10;
+import org.apache.cxf.ws.transfer.shared.faults.InvalidRepresentation;
+import org.apache.cxf.ws.transfer.shared.faults.UnknownDialect;
+
+/**
+ * Implementation of the WS-Fragment dialect.
+ */
+public class FragmentDialect implements Dialect {
+
+    @Resource
+    WebServiceContext context;
+
+    private final Map<String, FragmentDialectLanguage> languages;
+
+    private Pattern badXPathPattern;
+
+    private Pattern goodXPathPattern;
+
+    public FragmentDialect() {
+        languages = new HashMap<String, FragmentDialectLanguage>();
+        languages.put(FragmentDialectConstants.QNAME_LANGUAGE_IRI, new FragmentDialectLanguageQName());
+        languages.put(FragmentDialectConstants.XPATH10_LANGUAGE_IRI, new FragmentDialectLanguageXPath10());
+        if (badXPathPattern == null) {
+            StringBuilder sb = new StringBuilder();
+            sb.append("//@?");
+            sb.append(FragmentDialectLanguageQName.getQNamePatternString());
+            sb.append("$");
+            badXPathPattern = Pattern.compile(sb.toString());
+        }
+        if (goodXPathPattern == null) {
+            StringBuilder sb = new StringBuilder();
+            sb.append("/@?");
+            sb.append(FragmentDialectLanguageQName.getQNamePatternString());
+            sb.append("$");
+            goodXPathPattern = Pattern.compile(sb.toString());
+        }
+    }
+
+    @Override
+    public JAXBElement<ValueType> processGet(Get body, Representation representation) {
+        for (Object o : body.getAny()) {
+            if (o instanceof JAXBElement<?> && ((JAXBElement<?>)o).getDeclaredType() == ExpressionType.class) {
+                ExpressionType expression = (ExpressionType) ((JAXBElement<?>)o).getValue();
+                String languageIRI = expression.getLanguage();
+                languageIRI = languageIRI == null ? FragmentDialectConstants.XPATH10_LANGUAGE_IRI : languageIRI;
+                if (languages.containsKey(languageIRI)) {
+                    FragmentDialectLanguage language = languages.get(languageIRI);
+                    return generateGetResponse(language.getResourceFragment(representation, expression));
+                } else {
+                    throw new UnsupportedLanguage();
+                }
+            }
+        }
+        throw new SoapFault("wsf:Expression is not present.", getSoapVersion().getSender());
+    }
+
+    @Override
+    public Representation processPut(Put body, Representation representation) {
+        for (Object o : body.getAny()) {
+            if (o instanceof Fragment) {
+                Fragment fragment = (Fragment) o;
+                ExpressionType expression = fragment.getExpression();
+                ValueType value = fragment.getValue();
+
+                if (expression == null) {
+                    throw new SoapFault("wsf:Expression is not present.", getSoapVersion().getSender());
+                }
+                if (value == null) {
+                    value = new ValueType();
+                }
+                String languageIRI = expression.getLanguage();
+                languageIRI = languageIRI == null ? FragmentDialectConstants.XPATH10_LANGUAGE_IRI : languageIRI;
+                if (languages.containsKey(languageIRI)) {
+                    FragmentDialectLanguage language = languages.get(languageIRI);
+                    Object resourceFragment = language.getResourceFragment(representation, expression);
+                    String mode = expression.getMode();
+                    mode = mode == null ? FragmentDialectConstants.FRAGMENT_MODE_REPLACE : mode;
+                    if (resourceFragment == null && FragmentDialectConstants.FRAGMENT_MODE_REPLACE.equals(mode)
+                            && FragmentDialectConstants.XPATH10_LANGUAGE_IRI.equals(languageIRI)) {
+                        resourceFragment = language.getResourceFragment(representation, getParentXPath(expression));
+                        mode = FragmentDialectConstants.FRAGMENT_MODE_ADD;
+                    }
+                    return modifyRepresentation(resourceFragment, mode, value);
+                } else {
+                    throw new UnsupportedLanguage();
+                }
+            }
+        }
+        throw new SoapFault("wsf:Fragment is not present.", getSoapVersion().getSender());
+    }
+
+    @Override
+    public boolean processDelete(Delete body, Representation representation) {
+        throw new UnknownDialect();
+    }
+
+    @Override
+    public Representation processCreate(Create body) {
+        throw new UnknownDialect();
+    }
+
+    /**
+     * Register FragmentDialectLanguage object for IRI.
+     * @param iri
+     * @param language
+     */
+    public void registerLanguage(String iri, FragmentDialectLanguage language) {
+        if (languages.containsKey(iri)) {
+            throw new IllegalArgumentException(String.format("IRI \"%s\" is already registered", iri));
+        }
+        languages.put(iri, language);
+    }
+
+    /**
+     * Unregister FragmentDialectLanguage object for IRI.
+     * @param iri
+     */
+    public void unregisterLanguage(String iri) {
+        if (!languages.containsKey(iri)) {
+            throw new IllegalArgumentException(String.format("IRI \"%s\" is not registered", iri));
+        }
+        languages.remove(iri);
+    }
+
+    /**
+     * Generates Value element, which is returned as response to Get request.
+     * @param value Result of the XPath evaluation.
+     * @return
+     */
+    private JAXBElement<ValueType> generateGetResponse(Object value) {
+        if (value instanceof Node) {
+            return generateGetResponseNode((Node) value);
+        } else if (value instanceof NodeList) {
+            return generateGetResponseNodeList((NodeList) value);
+        } else if (value instanceof String) {
+            return generateGetResponseString((String) value);
+        }
+        ObjectFactory objectFactory = new ObjectFactory();
+        return objectFactory.createValue(new ValueType());
+    }
+
+    /**
+     * Generates Value element from NodeList.
+     * @param nodeList
+     * @return
+     */
+    private JAXBElement<ValueType> generateGetResponseNodeList(NodeList nodeList) {
+        ValueType resultValue = new ValueType();
+        for (int i = 0; i < nodeList.getLength(); i++) {
+            resultValue.getContent().add(nodeList.item(i));
+        }
+        ObjectFactory objectFactory = new ObjectFactory();
+        return objectFactory.createValue(resultValue);
+    }
+
+    /**
+     * Generates Value element from Node.
+     * @param node
+     * @return
+     */
+    private JAXBElement<ValueType> generateGetResponseNode(Node node) {
+        Document doc = DOMUtils.createDocument();
+        ValueType resultValue = new ValueType();
+        if (node.getNodeType() == Node.ATTRIBUTE_NODE) {
+            Element attrNodeEl = doc.createElementNS(
+                    FragmentDialectConstants.FRAGMENT_2011_03_IRI,
+                    FragmentDialectConstants.FRAGMENT_ATTR_NODE_NAME);
+            attrNodeEl.setAttribute(
+                    FragmentDialectConstants.FRAGMENT_ATTR_NODE_NAME_ATTR,
+                    node.getNodeName()
+            );
+            attrNodeEl.setTextContent(node.getNodeValue());
+            resultValue.getContent().add(attrNodeEl);
+        } else if (node.getNodeType() == Node.TEXT_NODE) {
+            Element textNodeEl = doc.createElementNS(
+                    FragmentDialectConstants.FRAGMENT_2011_03_IRI,
+                    FragmentDialectConstants.FRAGMENT_TEXT_NODE_NAME);
+            textNodeEl.setNodeValue(node.getNodeValue());
+            resultValue.getContent().add(textNodeEl);
+        } else if (node.getNodeType() == Node.ELEMENT_NODE) {
+            resultValue.getContent().add(node);
+        }
+        ObjectFactory objectFactory = new ObjectFactory();
+        return objectFactory.createValue(resultValue);
+    }
+
+    /**
+     * Generates Value element from String.
+     * @param value
+     * @return
+     */
+    private JAXBElement<ValueType> generateGetResponseString(String value) {
+        ValueType resultValue = new ValueType();
+        resultValue.getContent().add(value);
+        ObjectFactory objectFactory = new ObjectFactory();
+        return objectFactory.createValue(resultValue);
+    }
+
+    /**
+     * Returns expression containing XPath, which refers to parent element.
+     * @param expression
+     * @return
+     */
+    private ExpressionType getParentXPath(ExpressionType expression) {
+        String expr;
+        if (expression.getContent().size() == 1) {
+            expr = (String) expression.getContent().get(0);
+        } else {
+            throw new InvalidExpression();
+        }
+        if (badXPathPattern.matcher(expr).find()) {
+            throw new InvalidExpression();
+        }
+        if (goodXPathPattern.matcher(expr).find()) {
+            expression.getContent().clear();
+            expr = expr.replaceFirst(goodXPathPattern.pattern(), "");
+            if (expr.isEmpty()) {
+                expr = "/";
+            }
+            expression.getContent().add(expr);
+            return expression;
+        } else {
+            throw new InvalidExpression();
+        }
+    }
+
+    /**
+     * Process Put requests.
+     * @param resourceFragment Result of the XPath evaluation. It can be Node or NodeList.
+     * @param mode Mode defined in the Mode attribute.
+     * @param value Value defined in the Value element.
+     * @return Representation element, which is returned as response.
+     */
+    private Representation modifyRepresentation(
+            Object resourceFragment,
+            String mode,
+            ValueType value) {
+        if (resourceFragment instanceof Node) {
+            List<Node> nodeList = new ArrayList<Node>();
+            nodeList.add((Node) resourceFragment);
+            return modifyRepresentationMode(nodeList, mode, value);
+        } else if (resourceFragment instanceof NodeList) {
+            NodeList rfNodeList = (NodeList) resourceFragment;
+            List<Node> nodeList = new ArrayList<Node>();
+            for (int i = 0; i < rfNodeList.getLength(); i++) {
+                nodeList.add(rfNodeList.item(i));
+            }
+            return modifyRepresentationMode(nodeList, mode, value);
+        } else {
+            throw new InvalidExpression();
+        }
+    }
+
+    /**
+     * Process Put requests.
+     * @param mode Mode defined in the Mode attribute.
+     * @param value Value defined in the Value element.
+     * @return Representation element, which is returned as response.
+     */
+    private Representation modifyRepresentationMode(
+            List<Node> nodeList,
+            String mode,
+            ValueType value) {
+        switch (mode) {
+        case FragmentDialectConstants.FRAGMENT_MODE_REPLACE:
+            return modifyRepresentationModeReplace(nodeList, value);
+        case FragmentDialectConstants.FRAGMENT_MODE_ADD:
+            return modifyRepresentationModeAdd(nodeList, value);
+        case FragmentDialectConstants.FRAGMENT_MODE_INSERT_BEFORE:
+            return modifyRepresentationModeInsertBefore(nodeList, value);
+        case FragmentDialectConstants.FRAGMENT_MODE_INSERT_AFTER:
+            return modifyRepresentationModeInsertAfter(nodeList, value);
+        case FragmentDialectConstants.FRAGMENT_MODE_REMOVE:
+            return modifyRepresentationModeRemove(nodeList, value);
+        default:
+            throw new UnsupportedMode();
+        }
+    }
+
+    /**
+     * Process Put requests for Replace mode.
+     * @param value Value defined in the Value element.
+     * @return Representation element, which is returned as response.
+     */
+    private Representation modifyRepresentationModeReplace(
+            List<Node> nodeList,
+            ValueType value) {
+
+        if (nodeList.isEmpty()) {
+            throw new InvalidExpression();
+        }
+        Node firstNode = nodeList.get(0);
+        Document ownerDocument = firstNode.getOwnerDocument();
+        // if firstNode.getOwnerDocument == null the firstNode is ownerDocument
+        ownerDocument = ownerDocument == null ? (Document) firstNode : ownerDocument;
+        Node nextSibling = null;
+        Node parent = null;
+
+        for (Node node : nodeList) {
+            nextSibling = node.getNextSibling();
+            parent = removeNode(node);
+        }
+
+        addNode(ownerDocument, parent, nextSibling, value);
+
+        Representation representation = new Representation();
+        representation.setAny(ownerDocument.getDocumentElement());
+        return representation;
+    }
+
+    /**
+     * Process Put requests for Add mode.
+     * @param value Value defined in the Value element.
+     * @return Representation element, which is returned as response.
+     */
+    private Representation modifyRepresentationModeAdd(
+            List<Node> nodeList,
+            ValueType value) {
+        if (nodeList.isEmpty()) {
+            throw new InvalidExpression();
+        }
+        Node firstNode = nodeList.get(0);
+        Document ownerDocument = firstNode.getOwnerDocument();
+        // if firstNode.getOwnerDocument == null the firstNode is ownerDocument
+        ownerDocument = ownerDocument == null ? (Document) firstNode : ownerDocument;
+
+        for (Node node : nodeList) {
+            addNode(ownerDocument, node, null, value);
+        }
+        Representation representation = new Representation();
+        representation.setAny(ownerDocument.getDocumentElement());
+        return representation;
+    }
+
+    /**
+     * Process Put requests for InsertBefore mode.
+     * @param value Value defined in the Value element.
+     * @return Representation element, which is returned as response.
+     */
+    private Representation modifyRepresentationModeInsertBefore(
+            List<Node> nodeList,
+            ValueType value) {
+        if (nodeList.isEmpty()) {
+            throw new InvalidExpression();
+        }
+        Node firstNode = nodeList.get(0);
+        Document ownerDocument = firstNode.getOwnerDocument();
+        // if firstNode.getOwnerDocument == null the firstNode is ownerDocument
+        ownerDocument = ownerDocument == null ? (Document) firstNode : ownerDocument;
+
+        Node parent = firstNode.getParentNode();
+        if (parent == null && firstNode.getNodeType() != Node.DOCUMENT_NODE) {
+            throw new InvalidExpression();
+        }
+        if (parent == null) {
+            parent = firstNode;
+            if (((Document) parent).getDocumentElement() != null) {
+                throw new InvalidExpression();
+            }
+        }
+
+        for (Node node : nodeList) {
+            if (node.getNodeType() == Node.ATTRIBUTE_NODE) {
+                throw new InvalidRepresentation();
+            }
+            insertBefore(ownerDocument, parent, node, value);
+        }
+
+        Representation representation = new Representation();
+        representation.setAny(ownerDocument.getDocumentElement());
+        return representation;
+    }
+
+    /**
+     * Process Put requests for InsertAfter mode.
+     * @param value Value defined in the Value element.
+     * @return Representation element, which is returned as response.
+     */
+    private Representation modifyRepresentationModeInsertAfter(
+            List<Node> nodeList,
+            ValueType value) {
+        if (nodeList.isEmpty()) {
+            throw new InvalidExpression();
+        }
+        Node firstNode = nodeList.get(0);
+        Document ownerDocument = firstNode.getOwnerDocument();
+        // if firstNode.getOwnerDocument == null the firstNode is ownerDocument
+        ownerDocument = ownerDocument == null ? (Document) firstNode : ownerDocument;
+
+        Node parent = firstNode.getParentNode();
+        if (parent == null && firstNode.getNodeType() != Node.DOCUMENT_NODE) {
+            throw new InvalidExpression();
+        }
+        if (parent == null) {
+            parent = firstNode;
+            if (((Document) parent).getDocumentElement() != null) {
+                throw new InvalidExpression();
+            }
+        }
+
+        for (Node node : nodeList) {
+            if (node.getNodeType() == Node.ATTRIBUTE_NODE) {
+                throw new InvalidRepresentation();
+            }
+            insertAfter(ownerDocument, parent, node, value);
+        }
+
+        Representation representation = new Representation();
+        representation.setAny(ownerDocument.getDocumentElement());
+        return representation;
+    }
+
+    /**
+     * Process Put requests for Remove mode.
+     * @param value Value defined in the Value element.
+     * @return Representation element, which is returned as response.
+     */
+    private Representation modifyRepresentationModeRemove(
+            List<Node> nodeList,
+            ValueType value) {
+        if (nodeList.isEmpty()) {
+            throw new InvalidExpression();
+        }
+        Node firstNode = nodeList.get(0);
+        Document ownerDocument = firstNode.getOwnerDocument();
+        // if firstNode.getOwnerDocument == null the firstNode is ownerDocument
+        ownerDocument = ownerDocument == null ? (Document) firstNode : ownerDocument;
+
+        for (Node node : nodeList) {
+            removeNode(node);
+        }
+
+        Representation representation = new Representation();
+        representation.setAny(ownerDocument.getDocumentElement());
+        return representation;
+    }
+
+    /**
+     * Helper method. It removes Node and returns its parent.
+     * @param resourceFragment Node to remove.
+     * @return Parent of removed Node.
+     */
+    private Node removeNode(Node resourceFragment) {
+        Node parent = null;
+        if (resourceFragment.getNodeType() == Node.ATTRIBUTE_NODE) {
+            parent = ((Attr)resourceFragment).getOwnerElement();
+        } else {
+            parent = resourceFragment.getParentNode();
+        }
+        if (parent == null) {
+            // resourceFragment is Document Node
+            parent = resourceFragment;
+        }
+        if (resourceFragment.getNodeType() == Node.ATTRIBUTE_NODE) {
+            ((Element)parent).removeAttributeNode((Attr)resourceFragment);
+        } else {
+            if (parent != resourceFragment) {
+                parent.removeChild(resourceFragment);
+            } else {
+                // Both parent and resourceFragment are Document
+                Document doc = (Document) parent;
+                if (doc.getDocumentElement() != null) {
+                    doc.removeChild(doc.getDocumentElement());
+                }
+            }
+        }
+
+        return parent;
+    }
+
+    private void insertAfter(Document ownerDocument, Node parent, Node refChild, ValueType value) {
+        for (Object o : value.getContent()) {
+            if (o instanceof Node) {
+                Node node = (Node) o;
+
+                if (
+                        FragmentDialectConstants.FRAGMENT_2011_03_IRI.equals(node.getNamespaceURI())
+                                && FragmentDialectConstants.FRAGMENT_ATTR_NODE_NAME.equals(node.getLocalName())) {
+                    throw new InvalidRepresentation();
+                }
+
+                Node importedNode = ownerDocument.importNode(node, true);
+                if (parent.getNodeType() == Node.DOCUMENT_NODE) {
+                    parent.appendChild(importedNode);
+                } else {
+                    Node nextSibling = refChild.getNextSibling();
+                    if (nextSibling == null) {
+                        parent.appendChild(importedNode);
+                    } else {
+                        parent.insertBefore(importedNode, nextSibling);
+                    }
+                }
+            } else {
+                throw new InvalidExpression();
+            }
+        }
+    }
+
+    private void insertBefore(Document ownerDocument, Node parent, Node refChild, ValueType value) {
+        for (Object o : value.getContent()) {
+            if (o instanceof Node) {
+                Node node = (Node) o;
+
+                if (
+                        FragmentDialectConstants.FRAGMENT_2011_03_IRI.equals(node.getNamespaceURI())
+                                && FragmentDialectConstants.FRAGMENT_ATTR_NODE_NAME.equals(node.getLocalName())) {
+                    throw new InvalidRepresentation();
+                }
+
+                Node importedNode = ownerDocument.importNode(node, true);
+                if (parent.getNodeType() == Node.DOCUMENT_NODE) {
+                    parent.appendChild(importedNode);
+                } else {
+                    parent.insertBefore(importedNode, refChild);
+                }
+            } else {
+                throw new InvalidExpression();
+            }
+        }
+    }
+
+    /**
+     * Helper method. It adds new Node as the last child of parent.
+     * @param ownerDocument Document, where the Node is added.
+     * @param parent Parent, where the Node is added.
+     * @param value Value defined in the Value element. It represents newly added Node.
+     */
+    private void addNode(Document ownerDocument, Node parent, Node nextSibling, ValueType value) {
+        if (ownerDocument == parent && ownerDocument.getDocumentElement() != null) {
+            throw new InvalidRepresentation();
+        }
+        for (Object o : value.getContent()) {
+            if (o instanceof String) {
+                parent.setTextContent(parent.getTextContent() + ((String) o));
+            } else if (o instanceof Node) {
+                Node node = (Node) o;
+                if (
+                        FragmentDialectConstants.FRAGMENT_2011_03_IRI.equals(node.getNamespaceURI())
+                                && FragmentDialectConstants.FRAGMENT_ATTR_NODE_NAME.equals(node.getLocalName())) {
+                    String attrName = ((Element)node).getAttributeNS(
+                            FragmentDialectConstants.FRAGMENT_2011_03_IRI,
+                            FragmentDialectConstants.FRAGMENT_ATTR_NODE_NAME_ATTR);
+                    String attrValue = node.getTextContent();
+                    if (attrName == null) {
+                        throw new SoapFault("wsf:AttributeNode@name is not present.", getSoapVersion().getSender());
+                    }
+                    if (((Element) parent).hasAttribute(attrName)) {
+                        throw new InvalidRepresentation();
+                    }
+                    ((Element) parent).setAttribute(attrName, attrValue);
+                } else {
+                    // import the node to the ownerDocument
+                    Node importedNode = ownerDocument.importNode((Node) o, true);
+                    if (nextSibling == null) {
+                        parent.appendChild(importedNode);
+                    } else {
+                        parent.insertBefore(importedNode, nextSibling);
+                    }
+                }
+            } else {
+                throw new InvalidExpression();
+            }
+        }
+    }
+
+    private SoapVersion getSoapVersion() {
+        WrappedMessageContext wmc = (WrappedMessageContext) context.getMessageContext();
+        SoapMessage message = (SoapMessage) wmc.getWrappedMessage();
+        return message.getVersion();
+    }
+}

http://git-wip-us.apache.org/repos/asf/cxf/blob/517ef67f/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/FragmentDialectConstants.java
----------------------------------------------------------------------
diff --git a/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/FragmentDialectConstants.java b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/FragmentDialectConstants.java
new file mode 100644
index 0000000..6ffd009
--- /dev/null
+++ b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/FragmentDialectConstants.java
@@ -0,0 +1,51 @@
+/**
+ * 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.cxf.ws.transfer.dialect.fragment;
+
+/**
+ * Helper class for holding of constants.
+ */
+public final class FragmentDialectConstants {
+    
+    public static final String FRAGMENT_2011_03_IRI = "http://www.w3.org/2011/03/ws-fra";
+    
+    public static final String QNAME_LANGUAGE_IRI = "http://www.w3.org/2011/03/ws-fra/QName";
+    
+    public static final String XPATH10_LANGUAGE_IRI = "http://www.w3.org/2011/03/ws-fra/XPath10";
+    
+    public static final String FRAGMENT_TEXT_NODE_NAME = "TextNode";
+    
+    public static final String FRAGMENT_ATTR_NODE_NAME = "AttributeNode";
+    
+    public static final String FRAGMENT_ATTR_NODE_NAME_ATTR = "name";
+    
+    public static final String FRAGMENT_MODE_REPLACE = "http://www.w3.org/2011/03/ws-fra/Modes/Replace";
+    
+    public static final String FRAGMENT_MODE_ADD = "http://www.w3.org/2011/03/ws-fra/Modes/Add";
+    
+    public static final String FRAGMENT_MODE_INSERT_BEFORE = "http://www.w3.org/2011/03/ws-fra/Modes/InsertBefore";
+    
+    public static final String FRAGMENT_MODE_INSERT_AFTER = "http://www.w3.org/2011/03/ws-fra/Modes/InsertAfter";
+    
+    public static final String FRAGMENT_MODE_REMOVE = "http://www.w3.org/2011/03/ws-fra/Modes/Remove";
+    
+    private FragmentDialectConstants() {
+        
+    }
+}

http://git-wip-us.apache.org/repos/asf/cxf/blob/517ef67f/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/faults/FragmentFault.java
----------------------------------------------------------------------
diff --git a/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/faults/FragmentFault.java b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/faults/FragmentFault.java
new file mode 100644
index 0000000..3777238
--- /dev/null
+++ b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/faults/FragmentFault.java
@@ -0,0 +1,44 @@
+/**
+ * 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.cxf.ws.transfer.dialect.fragment.faults;
+
+import javax.xml.namespace.QName;
+import org.w3c.dom.Document;
+import org.w3c.dom.Element;
+import org.apache.cxf.binding.soap.SoapFault;
+import org.apache.cxf.helpers.DOMUtils;
+
+/**
+ * The parent for all WS-Fragment-specific faults.
+ */
+public abstract class FragmentFault extends SoapFault {
+
+    private static final long serialVersionUID = 2111286624025926462L;
+
+    public FragmentFault(String reason, String detail, QName faultCode) {
+        super(reason, faultCode);
+        if (detail != null) {
+            Document doc = DOMUtils.createDocument();
+            Element detailEl = doc.createElement("detail");
+            detailEl.setTextContent(detail);
+            setDetail(detailEl);
+        }
+    }
+
+}

http://git-wip-us.apache.org/repos/asf/cxf/blob/517ef67f/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/faults/InvalidExpression.java
----------------------------------------------------------------------
diff --git a/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/faults/InvalidExpression.java b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/faults/InvalidExpression.java
new file mode 100644
index 0000000..23da1bc
--- /dev/null
+++ b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/faults/InvalidExpression.java
@@ -0,0 +1,42 @@
+/**
+ * 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.cxf.ws.transfer.dialect.fragment.faults;
+
+import javax.xml.namespace.QName;
+import org.apache.cxf.ws.transfer.dialect.fragment.FragmentDialectConstants;
+
+/**
+ * Definition of the InvalidExpression SOAPFault.
+ */
+public class InvalidExpression extends FragmentFault {
+
+    private static final long serialVersionUID = -1920756304737648952L;
+
+    private static final String SUBCODE = "InvalidExpression";
+
+    private static final String REASON = "The specified Language expression is invalid.";
+
+    private static final String DETAIL = "The invalid language expression.";
+
+    public InvalidExpression() {
+        super(REASON, DETAIL,
+                new QName(FragmentDialectConstants.FRAGMENT_2011_03_IRI, SUBCODE));
+    }
+
+}

http://git-wip-us.apache.org/repos/asf/cxf/blob/517ef67f/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/faults/UnsupportedLanguage.java
----------------------------------------------------------------------
diff --git a/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/faults/UnsupportedLanguage.java b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/faults/UnsupportedLanguage.java
new file mode 100644
index 0000000..bb13b4c
--- /dev/null
+++ b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/faults/UnsupportedLanguage.java
@@ -0,0 +1,41 @@
+/**
+ * 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.cxf.ws.transfer.dialect.fragment.faults;
+
+import javax.xml.namespace.QName;
+import org.apache.cxf.ws.transfer.dialect.fragment.FragmentDialectConstants;
+
+/**
+ * Definition of the UnsupportedLanguage SOAPFault.
+ */
+public class UnsupportedLanguage extends FragmentFault {
+
+    private static final long serialVersionUID = 7627652802987243575L;
+
+    private static final String SUBCODE = "UnsupportedLanguage";
+
+    private static final String REASON = "The specified Language IRI is not supported.";
+
+    private static final String DETAIL = "The unsupported Language IRI.";
+
+    public UnsupportedLanguage() {
+        super(REASON, DETAIL,
+                new QName(FragmentDialectConstants.FRAGMENT_2011_03_IRI, SUBCODE));
+    }
+}

http://git-wip-us.apache.org/repos/asf/cxf/blob/517ef67f/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/faults/UnsupportedMode.java
----------------------------------------------------------------------
diff --git a/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/faults/UnsupportedMode.java b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/faults/UnsupportedMode.java
new file mode 100644
index 0000000..f38b912
--- /dev/null
+++ b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/faults/UnsupportedMode.java
@@ -0,0 +1,42 @@
+/**
+ * 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.cxf.ws.transfer.dialect.fragment.faults;
+
+import javax.xml.namespace.QName;
+import org.apache.cxf.ws.transfer.dialect.fragment.FragmentDialectConstants;
+
+/**
+ * Definition of the UnsupportedMode SOAPFault.
+ */
+public class UnsupportedMode extends FragmentFault {
+
+    private static final long serialVersionUID = -5824904523582078377L;
+
+    private static final String SUBCODE = "UnsupportedMode";
+
+    private static final String REASON = "The specified mode is not supported.";
+
+    private static final String DETAIL = "The unsupported Mode.";
+
+    public UnsupportedMode() {
+        super(REASON, DETAIL,
+                new QName(FragmentDialectConstants.FRAGMENT_2011_03_IRI, SUBCODE));
+    }
+
+}

http://git-wip-us.apache.org/repos/asf/cxf/blob/517ef67f/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/language/FragmentDialectLanguage.java
----------------------------------------------------------------------
diff --git a/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/language/FragmentDialectLanguage.java b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/language/FragmentDialectLanguage.java
new file mode 100644
index 0000000..8ff8018
--- /dev/null
+++ b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/language/FragmentDialectLanguage.java
@@ -0,0 +1,37 @@
+/**
+ * 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.cxf.ws.transfer.dialect.fragment.language;
+
+import org.apache.cxf.ws.transfer.Representation;
+import org.apache.cxf.ws.transfer.dialect.fragment.ExpressionType;
+
+/**
+ * Interface for FragmentDialect languages.
+ */
+public interface FragmentDialectLanguage {
+    
+    /**
+     * Returns fragment of resource, which is described by expression.
+     * @param representation Resource, from which is fragment computed.
+     * @param expression Expression written in the language.
+     * @return It can return org.w3c.dom.Node | org.w3c.dom.NodeList | String
+     */
+    Object getResourceFragment(Representation representation, ExpressionType expression);
+    
+}

http://git-wip-us.apache.org/repos/asf/cxf/blob/517ef67f/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/language/FragmentDialectLanguageQName.java
----------------------------------------------------------------------
diff --git a/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/language/FragmentDialectLanguageQName.java b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/language/FragmentDialectLanguageQName.java
new file mode 100644
index 0000000..a5d78ad
--- /dev/null
+++ b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/language/FragmentDialectLanguageQName.java
@@ -0,0 +1,134 @@
+/**
+ * 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.cxf.ws.transfer.dialect.fragment.language;
+
+import java.util.Iterator;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+import javax.xml.namespace.NamespaceContext;
+import org.w3c.dom.Element;
+import org.w3c.dom.Node;
+import org.w3c.dom.NodeList;
+import org.apache.cxf.helpers.XPathUtils;
+import org.apache.cxf.ws.transfer.Representation;
+import org.apache.cxf.ws.transfer.dialect.fragment.ExpressionType;
+import org.apache.cxf.ws.transfer.dialect.fragment.faults.InvalidExpression;
+
+/**
+ * Implementation of the QName language.
+ */
+public class FragmentDialectLanguageQName implements FragmentDialectLanguage {
+
+    private static Pattern qNamePattern;
+    
+    public FragmentDialectLanguageQName() {
+        if (qNamePattern == null) {
+            String qName = getQNamePatternString();
+            qNamePattern = Pattern.compile("^" + qName);
+        }
+    }
+
+    /**
+     * Returns regex string, which describes QName format.
+     * @return
+     */
+    public static String getQNamePatternString() {
+        // See http://www.w3.org/TR/REC-xml-names/#NT-PrefixedName
+        // NCNameStartChar
+        // see http://www.w3.org/TR/REC-xml-names/#NT-NCName
+        // and http://www.w3.org/TR/REC-xml/#NT-NameStartChar
+        String ncNameStartChar = "[A-Z]|_|[a-z]|[\\x{c0}-\\x{d6}]|[\\x{d8}-\\x{f6}]|[\\x{f8}-\\x{2ff}]|"
+                + "[\\x{370}-\\x{37d}]|[\\x{37f}-\\x{1fff}]|[\\x{200c}-\\x{200d}]|"
+                + "[\\x{2070}-\\x{218f}]|[\\x{2c00}-\\x{2fef}]|[\\x{3001}-\\x{d7ff}]|"
+                + "[\\x{f900}-\\x{fdcf}]|[\\x{fdf0}-\\x{fffd}]|[\\x{10000}-\\x{effff}]";
+        // NCNameChar
+        // see http://www.w3.org/TR/REC-xml/#NT-NameChar
+        String ncNameChar = ncNameStartChar
+                + "|-|\\.|[0-9]|\\x{b7}|[\\x{0300}-\\x{036f}]|[\\x{203f}-\\x{2040}]";
+        // NCName
+        // see http://www.w3.org/TR/REC-xml/#NT-Name
+        String ncName = String.format("(%s)(%s)*", ncNameStartChar, ncNameChar);
+        // QName
+        // see http://www.w3.org/TR/REC-xml-names/#NT-QName
+        return String.format("((%s):)?(%s)", ncName, ncName);
+    }
+    
+    @Override
+    public Object getResourceFragment(final Representation representation, ExpressionType expression) {
+        String expressionStr = getXPathFromQNameExpression(expression);
+        // Evaluate XPath
+        XPathUtils xu = new XPathUtils(new NamespaceContext() {
+            @Override
+            public String getNamespaceURI(String prefix) {
+                if (prefix != null && !prefix.isEmpty()) {
+                    Element resource = (Element) representation.getAny();
+                    return resource.getAttribute("xmlns:" + prefix);
+                } else {
+                    return null;
+                }
+            }
+
+            @Override
+            public String getPrefix(String s) {
+                throw new UnsupportedOperationException();
+            }
+
+            @Override
+            public Iterator<String> getPrefixes(String s) {
+                throw new UnsupportedOperationException();
+            }
+        });
+        Node resource = (Node) representation.getAny();
+        if (resource == null) {
+            // Returns empty NodeList
+            return new NodeList() {
+                @Override
+                public Node item(int i) {
+                    return null;
+                }
+
+                @Override
+                public int getLength() {
+                    return 0;
+                }
+            };
+        }
+        return xu.getValueList(expressionStr, resource);
+    }
+    
+    /**
+     * Converts expression in QName language to XPath expression.
+     * @param expression Expression in QName language.
+     * @return Expression in XPath language.
+     */
+    private String getXPathFromQNameExpression(ExpressionType expression) {
+        if (expression.getContent().size() == 1) {
+            String expressionValue = (String) expression.getContent().get(0);
+            Matcher m = qNamePattern.matcher(expressionValue);
+            if (m.matches()) {
+                return "/node()/" + expressionValue;
+            } else {
+                throw new InvalidExpression();
+            }
+        } else {
+            throw new InvalidExpression();
+        }
+    }
+    
+}

http://git-wip-us.apache.org/repos/asf/cxf/blob/517ef67f/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/language/FragmentDialectLanguageXPath10.java
----------------------------------------------------------------------
diff --git a/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/language/FragmentDialectLanguageXPath10.java b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/language/FragmentDialectLanguageXPath10.java
new file mode 100644
index 0000000..86bddab
--- /dev/null
+++ b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/dialect/fragment/language/FragmentDialectLanguageXPath10.java
@@ -0,0 +1,160 @@
+/**
+ * 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.cxf.ws.transfer.dialect.fragment.language;
+
+import java.util.Iterator;
+import javax.xml.namespace.NamespaceContext;
+import javax.xml.xpath.XPath;
+import javax.xml.xpath.XPathConstants;
+import javax.xml.xpath.XPathException;
+import javax.xml.xpath.XPathFactory;
+import org.w3c.dom.Element;
+import org.w3c.dom.Node;
+import org.w3c.dom.NodeList;
+import org.apache.cxf.helpers.DOMUtils;
+import org.apache.cxf.ws.transfer.Representation;
+import org.apache.cxf.ws.transfer.dialect.fragment.ExpressionType;
+import org.apache.cxf.ws.transfer.dialect.fragment.faults.InvalidExpression;
+
+/**
+ * Implementation of the XPath 1.0 language.
+ */
+public class FragmentDialectLanguageXPath10 implements FragmentDialectLanguage {
+
+    private static XPathFactory xpathFactory = XPathFactory.newInstance();
+
+    @Override
+    public Object getResourceFragment(final Representation representation, ExpressionType expression) {
+        String expressionStr = getXPathFromExpression(expression);
+        // Evaluate XPath
+        XPath xPath = xpathFactory.newXPath();
+        xPath.setNamespaceContext(new NamespaceContext() {
+
+            @Override
+            public String getNamespaceURI(String prefix) {
+                if (prefix != null && !prefix.isEmpty()) {
+                    Element resource = (Element) representation.getAny();
+                    return resource.getAttribute("xmlns:" + prefix);
+                } else {
+                    return null;
+                }
+            }
+
+            @Override
+            public String getPrefix(String string) {
+                throw new UnsupportedOperationException();
+            }
+
+            @Override
+            public Iterator<String> getPrefixes(String string) {
+                throw new UnsupportedOperationException();
+            }
+        });
+        try {
+            Object resource = representation.getAny();
+            if (resource == null) {
+                resource = DOMUtils.createDocument();
+            }
+            NodeList result = (NodeList) xPath.evaluate(
+                expressionStr, resource, XPathConstants.NODESET);
+            if (checkResultConstraints(result)) {
+                if (result.getLength() == 0) {
+                    return  null;
+                } else {
+                    return result;
+                }
+            } else {
+                return result.item(0);
+            }
+        } catch (XPathException ex) {
+            // See https://www.java.net/node/681793
+        }
+
+        try {
+            return (String) xPath.evaluate(
+                expressionStr, representation.getAny(), XPathConstants.STRING);
+        } catch (XPathException ex) {
+            throw new InvalidExpression();
+        }
+    }
+    
+    /**
+     * Get XPath from the Expression element.
+     * @param expression
+     * @return 
+     */
+    private String getXPathFromExpression(ExpressionType expression) {
+        if (expression.getContent().size() == 1) {
+            return (String) expression.getContent().get(0);
+        } else {
+            throw new InvalidExpression();
+        }
+    }
+    
+    /**
+     * Check if result from evaluation of XPath expression fullfils constraints
+     * defined in the specification.
+     * See http://www.w3.org/TR/ws-fragment/#IdResSubset
+     * @param result
+     * @return If the result is true, the server should return all sequence of elements,
+     *         otherwise it should return only the first element.
+     */
+    private boolean checkResultConstraints(NodeList result) {
+        if (result.getLength() > 0) {
+            Node firstNode = result.item(0);
+            if (firstNode.getNodeType() == Node.ELEMENT_NODE) {
+                Element firstEl = (Element) firstNode;
+                // QName attributes
+                String localName = firstEl.getLocalName();
+                String namespace = firstEl.getNamespaceURI();
+                Node parent = firstEl.getParentNode();
+                for (int i = 1; i < result.getLength(); i++) {
+                    Node node = result.item(i);
+                    if (node.getNodeType() == Node.ELEMENT_NODE) {
+                        Element element = (Element) node;
+                        if (!stringEquals(element.getLocalName(), localName)) {
+                            return false;
+                        }
+                        if (!stringEquals(element.getNamespaceURI(), namespace)) {
+                            return false;
+                        }
+                        if (element.getParentNode() != parent) {
+                            return false;
+                        }
+                    } else {
+                        return false;
+                    }
+                }
+            } else {
+                return false;
+            }
+        }
+        return true;
+    }
+    
+    /**
+     * Helper method for equation two strings, which can be nullable.
+     * @param str1
+     * @param str2
+     * @return 
+     */
+    private boolean stringEquals(String str1, String str2) {
+        return str1 == null ? str2 == null : str1.equals(str2);
+    }
+}

http://git-wip-us.apache.org/repos/asf/cxf/blob/517ef67f/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/manager/MemoryResourceManager.java
----------------------------------------------------------------------
diff --git a/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/manager/MemoryResourceManager.java b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/manager/MemoryResourceManager.java
new file mode 100644
index 0000000..9609013e
--- /dev/null
+++ b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/manager/MemoryResourceManager.java
@@ -0,0 +1,160 @@
+/**
+ * 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.cxf.ws.transfer.manager;
+
+import java.io.StringReader;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.UUID;
+import java.util.logging.Logger;
+
+import javax.annotation.Resource;
+import javax.xml.bind.JAXBElement;
+import javax.xml.namespace.QName;
+import javax.xml.stream.XMLStreamException;
+import javax.xml.ws.WebServiceContext;
+
+import org.w3c.dom.Document;
+import org.w3c.dom.Element;
+import org.apache.cxf.binding.soap.SoapFault;
+import org.apache.cxf.binding.soap.SoapMessage;
+import org.apache.cxf.binding.soap.SoapVersion;
+import org.apache.cxf.common.logging.LogUtils;
+import org.apache.cxf.helpers.DOMUtils;
+import org.apache.cxf.jaxws.context.WrappedMessageContext;
+import org.apache.cxf.staxutils.StaxUtils;
+import org.apache.cxf.ws.addressing.ReferenceParametersType;
+import org.apache.cxf.ws.transfer.Representation;
+import org.apache.cxf.ws.transfer.shared.faults.UnknownResource;
+
+/**
+ * In memory implementation for ResourceManager interface.
+ */
+public class MemoryResourceManager implements ResourceManager {
+
+    public static final String REF_NAMESPACE = "http://cxf.apache.org/rt/ws/transfer/MemoryResourceManager";
+
+    public static final String REF_LOCAL_NAME = "uuid";
+
+    private static final Logger LOG = LogUtils.getL7dLogger(MemoryResourceManager.class);
+
+    protected Map<String, String> storage;
+
+    @Resource
+    private WebServiceContext context;
+
+    public MemoryResourceManager() {
+        storage = new HashMap<String, String>();
+    }
+
+    @Override
+    public Representation get(ReferenceParametersType ref) {
+        String uuid = getUUID(ref);
+        if (!storage.containsKey(uuid)) {
+            throw new UnknownResource();
+        }
+        String resource = storage.get(uuid);
+        if (resource.isEmpty()) {
+            return new Representation();
+        } else {
+            Document doc = null;
+            try {
+                doc = StaxUtils.read(new StringReader(storage.get(uuid)));
+            } catch (XMLStreamException e) {
+                LOG.severe(e.getLocalizedMessage());
+                throw new SoapFault("Internal Error", getSoapVersion().getReceiver());
+            }
+            Representation representation = new Representation();
+            representation.setAny(doc.getDocumentElement());
+            return representation;
+        }
+    }
+
+    @Override
+    public void delete(ReferenceParametersType ref) {
+        String uuid = getUUID(ref);
+        if (!storage.containsKey(uuid)) {
+            throw new UnknownResource();
+        }
+        storage.remove(uuid);
+    }
+
+    @Override
+    public void put(ReferenceParametersType ref, Representation newRepresentation) {
+        String uuid = getUUID(ref);
+        if (!storage.containsKey(uuid)) {
+            throw new UnknownResource();
+        }
+        Element representationEl = (Element) newRepresentation.getAny();
+        if (representationEl == null) {
+            storage.put(uuid, "");
+        } else {
+            storage.put(uuid, StaxUtils.toString(representationEl));
+        }
+    }
+
+    @Override
+    public ReferenceParametersType create(Representation initRepresentation) {
+        // Store xmlResource
+        String uuid = UUID.randomUUID().toString();
+        Element representationEl = (Element) initRepresentation.getAny();
+        if (representationEl == null) {
+            storage.put(uuid, "");
+        } else {
+            storage.put(uuid, StaxUtils.toString(representationEl));
+        }
+
+        Element uuidEl = DOMUtils.createDocument().createElementNS(REF_NAMESPACE, REF_LOCAL_NAME);
+        uuidEl.setTextContent(uuid);
+
+        // Create referenceParameter
+        ReferenceParametersType refParam = new ReferenceParametersType();
+        refParam.getAny().add(uuidEl);
+        return refParam;
+    }
+
+    private String getUUID(ReferenceParametersType ref) {
+        for (Object object : ref.getAny()) {
+            if (object instanceof JAXBElement) {
+                JAXBElement<?> element = (JAXBElement<?>) object;
+                QName qName = element.getName();
+                if (
+                        REF_NAMESPACE.equals(qName.getNamespaceURI())
+                                && REF_LOCAL_NAME.equals(qName.getLocalPart())) {
+                    return (String) element.getValue();
+                }
+            } else if (object instanceof Element) {
+                Element element = (Element) object;
+                if (
+                        REF_NAMESPACE.equals(element.getNamespaceURI())
+                                && REF_LOCAL_NAME.equals(element.getLocalName())) {
+                    return element.getTextContent();
+                }
+            }
+        }
+        throw new UnknownResource();
+    }
+
+    private SoapVersion getSoapVersion() {
+        WrappedMessageContext wmc = (WrappedMessageContext) context.getMessageContext();
+        SoapMessage message = (SoapMessage) wmc.getWrappedMessage();
+        return message.getVersion();
+    }
+}

http://git-wip-us.apache.org/repos/asf/cxf/blob/517ef67f/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/manager/ResourceManager.java
----------------------------------------------------------------------
diff --git a/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/manager/ResourceManager.java b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/manager/ResourceManager.java
new file mode 100644
index 0000000..7dbc6ac
--- /dev/null
+++ b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/manager/ResourceManager.java
@@ -0,0 +1,59 @@
+/**
+ * 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.cxf.ws.transfer.manager;
+
+import org.apache.cxf.ws.addressing.ReferenceParametersType;
+import org.apache.cxf.ws.transfer.Representation;
+
+/**
+ * Interface for managing resource representations.
+ */
+public interface ResourceManager {
+    
+    /**
+     * Returns Representation object given by reference parameter.
+     * @param ref Reference parameter returned by create method.
+     * @return Representation object containing the XML resource.
+     * @see ResourceManager#create(org.apache.cxf.ws.transfer.Representation) 
+     */
+    Representation get(ReferenceParametersType ref);
+    
+    /**
+     * Deletes Representation object given by reference parameter.
+     * @param ref Reference parameter returned by create method.
+     * @see ResourceManager#create(org.apache.cxf.ws.transfer.Representation)
+     */
+    void delete(ReferenceParametersType ref);
+    
+    /**
+     * Replaces Representation object given by reference parameter with newRepresentation.
+     * @param ref Reference parameter returned by create method.
+     * @param newRepresentation New Representation object, which will replace the old one.
+     * @see ResourceManager#create(org.apache.cxf.ws.transfer.Representation)
+     */
+    void put(ReferenceParametersType ref, Representation newRepresentation);
+    
+    /**
+     * Creates new Representation object from initRepresenation.
+     * @param initRepresentation Representation object containing initial XML resource.
+     * @return Reference parameter for newly created Representation object.
+     */
+    ReferenceParametersType create(Representation initRepresentation);
+}

http://git-wip-us.apache.org/repos/asf/cxf/blob/517ef67f/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/resource/Resource.java
----------------------------------------------------------------------
diff --git a/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/resource/Resource.java b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/resource/Resource.java
new file mode 100644
index 0000000..3280e39
--- /dev/null
+++ b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/resource/Resource.java
@@ -0,0 +1,101 @@
+/**
+ * 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.cxf.ws.transfer.resource;
+
+import javax.jws.WebMethod;
+import javax.jws.WebParam;
+import javax.jws.WebResult;
+import javax.jws.WebService;
+import javax.jws.soap.SOAPBinding;
+import javax.xml.ws.Action;
+import javax.xml.ws.soap.Addressing;
+import org.apache.cxf.ws.transfer.Delete;
+import org.apache.cxf.ws.transfer.DeleteResponse;
+import org.apache.cxf.ws.transfer.Get;
+import org.apache.cxf.ws.transfer.GetResponse;
+import org.apache.cxf.ws.transfer.Put;
+import org.apache.cxf.ws.transfer.PutResponse;
+import org.apache.cxf.ws.transfer.shared.TransferConstants;
+
+/**
+ * The interface definition of a Resource web service, according to the specification.
+ */
+@WebService(targetNamespace = TransferConstants.TRANSFER_2011_03_NAMESPACE,
+        name = TransferConstants.NAME_RESOURCE)
+@SOAPBinding(parameterStyle = SOAPBinding.ParameterStyle.BARE)
+@Addressing(enabled = true, required = true)
+public interface Resource {
+
+    @Action(
+            input = TransferConstants.ACTION_GET,
+            output = TransferConstants.ACTION_GET_RESPONSE)
+    @WebMethod(operationName = TransferConstants.NAME_OPERATION_GET)
+    @WebResult(
+            name = TransferConstants.NAME_MESSAGE_GET_RESPONSE,
+            targetNamespace = TransferConstants.TRANSFER_2011_03_NAMESPACE,
+            partName = "Body"
+    )
+    GetResponse get(
+        @WebParam(
+                name = TransferConstants.NAME_MESSAGE_GET,
+                targetNamespace = TransferConstants.TRANSFER_2011_03_NAMESPACE,
+                partName = "Body"
+        )
+        Get body
+    );
+
+    @Action(
+            input = TransferConstants.ACTION_DELETE,
+            output = TransferConstants.ACTION_DELETE_RESPONSE
+    )
+    @WebMethod(operationName = TransferConstants.NAME_OPERATION_DELETE)
+    @WebResult(
+            name = TransferConstants.NAME_MESSAGE_DELETE_RESPONSE,
+            targetNamespace = TransferConstants.TRANSFER_2011_03_NAMESPACE,
+            partName = "Body"
+    )
+    DeleteResponse delete(
+        @WebParam(
+                name = TransferConstants.NAME_MESSAGE_DELETE,
+                targetNamespace = TransferConstants.TRANSFER_2011_03_NAMESPACE,
+                partName = "Body"
+        )
+        Delete body
+    );
+
+    @Action(
+            input = TransferConstants.ACTION_PUT,
+            output = TransferConstants.ACTION_PUT_RESPONSE
+    )
+    @WebMethod(operationName = TransferConstants.NAME_OPERATION_PUT)
+    @WebResult(
+            name = TransferConstants.NAME_MESSAGE_PUT_RESPONSE,
+            targetNamespace = TransferConstants.TRANSFER_2011_03_NAMESPACE,
+            partName = "Body"
+    )
+    PutResponse put(
+        @WebParam(
+                name = TransferConstants.NAME_MESSAGE_PUT,
+                targetNamespace = TransferConstants.TRANSFER_2011_03_NAMESPACE,
+                partName = "Body"
+        )
+        Put body
+    );
+}

http://git-wip-us.apache.org/repos/asf/cxf/blob/517ef67f/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/resource/ResourceLocal.java
----------------------------------------------------------------------
diff --git a/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/resource/ResourceLocal.java b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/resource/ResourceLocal.java
new file mode 100644
index 0000000..49333d6
--- /dev/null
+++ b/rt/ws/transfer/src/main/java/org/apache/cxf/ws/transfer/resource/ResourceLocal.java
@@ -0,0 +1,191 @@
+/**
+ * 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.cxf.ws.transfer.resource;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import javax.xml.ws.WebServiceContext;
+import org.apache.cxf.jaxws.context.WrappedMessageContext;
+import org.apache.cxf.ws.addressing.AddressingProperties;
+import org.apache.cxf.ws.addressing.JAXWSAConstants;
+import org.apache.cxf.ws.addressing.ReferenceParametersType;
+import org.apache.cxf.ws.transfer.Delete;
+import org.apache.cxf.ws.transfer.DeleteResponse;
+import org.apache.cxf.ws.transfer.Get;
+import org.apache.cxf.ws.transfer.GetResponse;
+import org.apache.cxf.ws.transfer.Put;
+import org.apache.cxf.ws.transfer.PutResponse;
+import org.apache.cxf.ws.transfer.Representation;
+import org.apache.cxf.ws.transfer.dialect.Dialect;
+import org.apache.cxf.ws.transfer.dialect.fragment.FragmentDialect;
+import org.apache.cxf.ws.transfer.dialect.fragment.FragmentDialectConstants;
+import org.apache.cxf.ws.transfer.manager.ResourceManager;
+import org.apache.cxf.ws.transfer.shared.faults.UnknownDialect;
+import org.apache.cxf.ws.transfer.validationtransformation.ResourceTypeIdentifier;
+import org.apache.cxf.ws.transfer.validationtransformation.ValidAndTransformHelper;
+
+/**
+ * Implementation of the Resource interface for resources, which are created locally.
+ * @see org.apache.cxf.ws.transfer.resourcefactory.resolver.ResourceResolver
+ */
+public class ResourceLocal implements Resource {
+    
+    @javax.annotation.Resource
+    protected WebServiceContext context;
+    
+    protected ResourceManager manager;
+    
+    protected List<ResourceTypeIdentifier> resourceTypeIdentifiers;
+    
+    protected Map<String, Dialect> dialects;
+
+    public ResourceLocal() {
+        dialects = new HashMap<String, Dialect>();
+        dialects.put(FragmentDialectConstants.FRAGMENT_2011_03_IRI, new FragmentDialect());
+    }
+    
+    public ResourceManager getManager() {
+        return manager;
+    }
+
+    public void setManager(ResourceManager manager) {
+        this.manager = manager;
+    }
+
+    public List<ResourceTypeIdentifier> getResourceTypeIdentifiers() {
+        if (resourceTypeIdentifiers == null) {
+            resourceTypeIdentifiers = new ArrayList<>();
+        }
+        return resourceTypeIdentifiers;
+    }
+
+    public void setResourceTypeIdentifiers(List<ResourceTypeIdentifier> resourceTypeIdentifiers) {
+        this.resourceTypeIdentifiers = resourceTypeIdentifiers;
+    }
+    
+    /**
+     * Register Dialect object for URI.
+     * @param iri
+     * @param dialect 
+     */
+    public void registerDialect(String iri, Dialect dialect) {
+        if (dialects.containsKey(iri)) {
+            throw new IllegalArgumentException(String.format("IRI \"%s\" is already registered", iri));
+        }
+        dialects.put(iri, dialect);
+    }
+    
+    /**
+     * Unregister dialect URI.
+     * @param iri 
+     */
+    public void unregisterDialect(String iri) {
+        if (!dialects.containsKey(iri)) {
+            throw new IllegalArgumentException(String.format("IRI \"%s\" is not registered", iri));
+        }
+        dialects.remove(iri);
+    }
+    
+    @Override
+    public GetResponse get(Get body) {
+        // Getting reference paramaters
+        AddressingProperties addrProps = (AddressingProperties) ((WrappedMessageContext) context
+                .getMessageContext()).getWrappedMessage()
+                .getContextualProperty(JAXWSAConstants.ADDRESSING_PROPERTIES_INBOUND);
+        ReferenceParametersType refParams = addrProps
+                .getToEndpointReference()
+                .getReferenceParameters();
+        GetResponse response = new GetResponse();
+        // Getting representation from the ResourceManager
+        Representation representation = manager.get(refParams);
+        // Dialect processing
+        if (body.getDialect() != null && !body.getDialect().isEmpty()) {
+            if (dialects.containsKey(body.getDialect())) {
+                Dialect dialect = dialects.get(body.getDialect());
+                // Send fragment of resource instead it's representation.
+                response.getAny().add(dialect.processGet(body, representation));
+            } else {
+                throw new UnknownDialect();
+            }
+        } else {
+            // Send representation obtained from ResourceManager.
+            response.setRepresentation(representation);
+        }
+        return response;
+    }
+
+    @Override
+    public DeleteResponse delete(Delete body) {
+        // Getting reference paramaters
+        AddressingProperties addrProps = (AddressingProperties) ((WrappedMessageContext) context
+                .getMessageContext()).getWrappedMessage()
+                .getContextualProperty(JAXWSAConstants.ADDRESSING_PROPERTIES_INBOUND);
+        ReferenceParametersType refParams = addrProps
+                .getToEndpointReference()
+                .getReferenceParameters();
+        boolean delete = true;
+        // Dialect processing
+        if (body.getDialect() != null && !body.getDialect().isEmpty()) {
+            if (dialects.containsKey(body.getDialect())) {
+                Dialect dialect = dialects.get(body.getDialect());
+                delete = dialect.processDelete(body, manager.get(refParams));
+            } else {
+                throw new UnknownDialect();
+            }
+        }
+        if (delete) {
+            manager.delete(refParams);
+        }
+        return new DeleteResponse();
+    }
+
+    @Override
+    public PutResponse put(Put body) {
+        // Getting reference paramaters
+        AddressingProperties addrProps = (AddressingProperties) ((WrappedMessageContext) context
+                .getMessageContext()).getWrappedMessage()
+                .getContextualProperty(JAXWSAConstants.ADDRESSING_PROPERTIES_INBOUND);
+        ReferenceParametersType refParams = addrProps
+                .getToEndpointReference()
+                .getReferenceParameters();
+        // Getting representation from the ResourceManager
+        Representation storedRepresentation = manager.get(refParams);
+        // Getting representation from the incoming SOAP message. This representation will be stored.
+        Representation putRepresentation = body.getRepresentation();
+        // Dialect processing
+        if (body.getDialect() != null && !body.getDialect().isEmpty()) {
+            if (dialects.containsKey(body.getDialect())) {
+                Dialect dialect = dialects.get(body.getDialect());
+                putRepresentation = dialect.processPut(body, storedRepresentation);
+            } else {
+                throw new UnknownDialect();
+            }
+        }
+        ValidAndTransformHelper.validationAndTransformation(
+                resourceTypeIdentifiers, putRepresentation, storedRepresentation);
+        manager.put(refParams, putRepresentation);
+        PutResponse response = new PutResponse();
+        response.setRepresentation(putRepresentation);
+        return response;
+    }
+    
+}


Mime
View raw message