Copied: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/ServiceMediatorFactory.java (from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/ServiceMediatorProcessorConfigurator.java) URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/ServiceMediatorFactory.java?p2=incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/ServiceMediatorFactory.java&p1=incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/ServiceMediatorProcessorConfigurator.java&r1=389703&r2=390358&rev=390358&view=diff ============================================================================== --- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/ServiceMediatorProcessorConfigurator.java (original) +++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/ServiceMediatorFactory.java Fri Mar 31 00:21:31 2006 @@ -20,26 +20,26 @@ import javax.xml.namespace.QName; -import org.apache.synapse.Processor; import org.apache.synapse.SynapseEnvironment; import org.apache.synapse.SynapseException; -import org.apache.synapse.processors.mediatortypes.axis2.ServiceMediatorProcessor; +import org.apache.synapse.api.Mediator; +import org.apache.synapse.processors.mediators.types.axis2.ServiceMediator; import org.apache.axiom.om.OMElement; import org.apache.axiom.om.OMAttribute; -public class ServiceMediatorProcessorConfigurator extends AbstractProcessorConfigurator { +public class ServiceMediatorFactory extends AbstractMediatorFactory { private static final QName tagName = new QName(Constants.SYNAPSE_NAMESPACE, "servicemediator"); - public Processor createProcessor(SynapseEnvironment se, OMElement el) { - ServiceMediatorProcessor smp = new ServiceMediatorProcessor(); - super.setNameOnProcessor(se,el,smp); + public Mediator createMediator(SynapseEnvironment se, OMElement el) { + ServiceMediator sm = new ServiceMediator(); + super.setNameOnMediator(se,el,sm); OMAttribute attr = el.getAttribute(new QName("service")); if (attr == null) throw new SynapseException( - "<servicemediator> must have <service> attribute"); - smp.setServiceName(attr.getAttributeValue()); - return smp; + "<servicemediator> must have 'service' attribute"); + sm.setServiceName(attr.getAttributeValue()); + return sm; } public QName getTagQName() {
Copied: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/StageMediatorFactory.java (from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/StageProcessorConfigurator.java) URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/StageMediatorFactory.java?p2=incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/StageMediatorFactory.java&p1=incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/StageProcessorConfigurator.java&r1=389703&r2=390358&rev=390358&view=diff ============================================================================== --- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/StageProcessorConfigurator.java (original) +++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/StageMediatorFactory.java Fri Mar 31 00:21:31 2006 @@ -19,17 +19,17 @@ import javax.xml.namespace.QName; import org.apache.synapse.xml.Constants; -import org.apache.synapse.Processor; import org.apache.synapse.SynapseEnvironment; -import org.apache.synapse.processors.StageProcessor; +import org.apache.synapse.api.Mediator; +import org.apache.synapse.mediators.base.StageMediator; import org.apache.axiom.om.OMElement; /** * *<xmp><synapse:stage name="optional"> do everything in here </synapse:stage></xmp> */ -public class StageProcessorConfigurator extends - AbstractListProcessorConfigurator { +public class StageMediatorFactory extends + AbstractListMediatorFactory{ private static final QName STAGE_Q = new QName(Constants.SYNAPSE_NAMESPACE, "stage"); @@ -37,10 +37,10 @@ return STAGE_Q; } - public Processor createProcessor(SynapseEnvironment se, OMElement el) { - StageProcessor sp = new StageProcessor(); - super.addChildrenAndSetName(se, el, sp); - return sp; + public Mediator createMediator(SynapseEnvironment se, OMElement el) { + StageMediator sm = new StageMediator(); + super.addChildrenAndSetName(se, el, sm); + return sm; } } Copied: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/SynapseMediatorFactory.java (from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/SynapseProcessorConfigurator.java) URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/SynapseMediatorFactory.java?p2=incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/SynapseMediatorFactory.java&p1=incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/SynapseProcessorConfigurator.java&r1=389703&r2=390358&rev=390358&view=diff ============================================================================== --- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/SynapseProcessorConfigurator.java (original) +++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/SynapseMediatorFactory.java Fri Mar 31 00:21:31 2006 @@ -18,13 +18,13 @@ import javax.xml.namespace.QName; -import org.apache.synapse.Processor; import org.apache.synapse.SynapseEnvironment; -import org.apache.synapse.processors.SynapseProcessor; +import org.apache.synapse.api.Mediator; +import org.apache.synapse.mediators.base.SynapseMediator; import org.apache.axiom.om.OMElement; -public class SynapseProcessorConfigurator extends - AbstractListProcessorConfigurator { +public class SynapseMediatorFactory extends + AbstractListMediatorFactory { private final static QName tagname = new QName(Constants.SYNAPSE_NAMESPACE, "synapse"); @@ -33,10 +33,10 @@ return tagname; } - public Processor createProcessor(SynapseEnvironment se, OMElement el) { - SynapseProcessor sp = new SynapseProcessor(); - super.addChildrenAndSetName(se, el, sp); - return sp; + public Mediator createMediator(SynapseEnvironment se, OMElement el) { + SynapseMediator sm = new SynapseMediator(); + super.addChildrenAndSetName(se, el, sm); + return sm; } } Copied: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/XPathMediatorFactory.java (from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/XPathProcessorConfigurator.java) URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/XPathMediatorFactory.java?p2=incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/XPathMediatorFactory.java&p1=incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/XPathProcessorConfigurator.java&r1=389703&r2=390358&rev=390358&view=diff ============================================================================== --- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/XPathProcessorConfigurator.java (original) +++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/XPathMediatorFactory.java Fri Mar 31 00:21:31 2006 @@ -20,10 +20,11 @@ import javax.xml.namespace.QName; -import org.apache.synapse.Processor; + import org.apache.synapse.SynapseEnvironment; import org.apache.synapse.SynapseException; -import org.apache.synapse.processors.rules.XPathProcessor; +import org.apache.synapse.api.Mediator; +import org.apache.synapse.mediators.rules.XPathMediator; import org.apache.axiom.om.OMElement; import org.apache.axiom.om.OMAttribute; import org.apache.axiom.om.OMNamespace; @@ -36,8 +37,8 @@ * if the test is true * */ -public class XPathProcessorConfigurator extends - AbstractListProcessorConfigurator { +public class XPathMediatorFactory extends + AbstractListMediatorFactory { private static final String XPATH = "xpath"; private static final QName XPATH_Q = new QName(Constants.SYNAPSE_NAMESPACE, @@ -51,10 +52,10 @@ * @see org.apache.synapse.spi.Processor#compile(org.apache.synapse.api.SynapseEnvironment, * org.apache.axis2.om.OMElement) */ - public Processor createProcessor(SynapseEnvironment se, OMElement el) { - XPathProcessor xp = new XPathProcessor(); + public Mediator createMediator(SynapseEnvironment se, OMElement el) { + XPathMediator xm = new XPathMediator(); - super.addChildrenAndSetName(se, el, xp); + super.addChildrenAndSetName(se, el, xm); OMAttribute expr = el.getAttribute(XPATH_EXPRESSION_ATT_Q); if (expr == null) { @@ -62,14 +63,14 @@ + XPATH_EXPRESSION_ATT_Q + " attribute: " + el.toString()); } - xp.setXPathExpr(expr.getAttributeValue()); + xm.setXPathExpr(expr.getAttributeValue()); Iterator it = el.getAllDeclaredNamespaces(); while (it.hasNext()) { OMNamespace n = (OMNamespace) it.next(); - xp.addXPathNamespace(n.getPrefix(), n.getName()); + xm.addXPathNamespace(n.getPrefix(), n.getName()); } - return xp; + return xm; } public QName getTagQName() { --------------------------------------------------------------------- To unsubscribe, e-mail: [EMAIL PROTECTED] For additional commands, e-mail: [EMAIL PROTECTED]
