#set( $symbol_pound = '#' ) #set( $symbol_dollar = '$' ) #set( $symbol_escape = '\' ) /* * 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 ${package}.${policyName}; import static javax.xml.stream.XMLStreamConstants.END_ELEMENT; import static javax.xml.stream.XMLStreamConstants.START_ELEMENT; import javax.xml.namespace.QName; import javax.xml.stream.XMLStreamException; import javax.xml.stream.XMLStreamReader; import javax.xml.stream.XMLStreamWriter; import org.apache.tuscany.sca.contribution.processor.ContributionReadException; import org.apache.tuscany.sca.contribution.processor.ContributionResolveException; import org.apache.tuscany.sca.contribution.processor.ContributionWriteException; import org.apache.tuscany.sca.contribution.processor.ProcessorContext; import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor; import org.apache.tuscany.sca.contribution.resolver.ModelResolver; import org.apache.tuscany.sca.core.FactoryExtensionPoint; /** * * @version ${symbol_dollar}Rev${symbol_dollar} ${symbol_dollar}Date${symbol_dollar} */ public class ${policyName}PolicyProcessor implements StAXArtifactProcessor<${policyName}Policy> { public ${policyName}PolicyProcessor(FactoryExtensionPoint modelFactories) { } @Override public QName getArtifactType() { return ${policyName}Policy.POLICY_QNAME; } @Override public ${policyName}Policy read(XMLStreamReader reader, ProcessorContext context) throws ContributionReadException, XMLStreamException { ${policyName}Policy policy = new ${policyName}Policy(); int event = reader.getEventType(); QName name = null; while (reader.hasNext()) { event = reader.getEventType(); switch (event) { case START_ELEMENT : { name = reader.getName(); if ( name.equals(${policyName}Policy.POLICY_QNAME) ) { String config = reader.getAttributeValue(null, "name"); policy.setConfigProperty(config); } break; } } if ( event == END_ELEMENT ) { if ( ${policyName}Policy.POLICY_QNAME.equals(reader.getName()) ) { break; } } //Read the next element if (reader.hasNext()) { reader.next(); } } return policy; } @Override public void write(${policyName}Policy policy, XMLStreamWriter writer, ProcessorContext context) throws ContributionWriteException, XMLStreamException { String prefix = "tuscany"; writer.writeStartElement(prefix, ${policyName}Policy.POLICY_QNAME.getLocalPart(), ${policyName}Policy.POLICY_QNAME.getNamespaceURI()); writer.writeNamespace("tuscany", ${policyName}Policy.SCA11_TUSCANY_NS); if (policy.getConfigProperty() != null) { writer.writeAttribute("name", policy.getConfigProperty()); } writer.writeEndElement(); } @Override public Class<${policyName}Policy> getModelType() { return ${policyName}Policy.class; } @Override public void resolve(${policyName}Policy arg0, ModelResolver arg1, ProcessorContext context) throws ContributionResolveException { } }