You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@synapse.apache.org by pz...@apache.org on 2005/11/25 19:14:07 UTC
svn commit: r348991 - in /incubator/synapse/trunk/scratch/prototype3:
SpringMediator/org/apache/synapse/processors/mediatortypes/spring/
src/org/apache/synapse/processors/ src/org/apache/synapse/xml/
Author: pzf
Date: Fri Nov 25 10:13:33 2005
New Revision: 348991
URL: http://svn.apache.org/viewcvs?rev=348991&view=rev
Log:
Adding the files I forgot earlier. I hope that my new SubClipse install is going to remove my SVN woes
Added:
incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/processors/InProcessor.java
incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/processors/NeverProcessor.java
incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/processors/OutProcessor.java
incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/processors/RefProcessor.java
incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/xml/InProcessorConfigurator.java
incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/xml/NeverProcessorConfigurator.java
incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/xml/OutProcessorConfigurator.java
incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/xml/RefProcessorConfigurator.java
Modified:
incubator/synapse/trunk/scratch/prototype3/SpringMediator/org/apache/synapse/processors/mediatortypes/spring/SpringMediatorProcessorConfigurator.java
Modified: incubator/synapse/trunk/scratch/prototype3/SpringMediator/org/apache/synapse/processors/mediatortypes/spring/SpringMediatorProcessorConfigurator.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/scratch/prototype3/SpringMediator/org/apache/synapse/processors/mediatortypes/spring/SpringMediatorProcessorConfigurator.java?rev=348991&r1=348990&r2=348991&view=diff
==============================================================================
--- incubator/synapse/trunk/scratch/prototype3/SpringMediator/org/apache/synapse/processors/mediatortypes/spring/SpringMediatorProcessorConfigurator.java (original)
+++ incubator/synapse/trunk/scratch/prototype3/SpringMediator/org/apache/synapse/processors/mediatortypes/spring/SpringMediatorProcessorConfigurator.java Fri Nov 25 10:13:33 2005
@@ -25,9 +25,9 @@
public class SpringMediatorProcessorConfigurator extends AbstractProcessorConfigurator {
private static final QName tagName = new QName(Constants.SYNAPSE_NAMESPACE+"/spring", "springmediator");
- public Processor compile(SynapseEnvironment se, OMElement el) {
+ public Processor createProcessor(SynapseEnvironment se, OMElement el) {
SpringMediatorProcessor smp = new SpringMediatorProcessor();
- super.compile(se,el,smp);
+ super.setNameOnProcessor(se,el,smp);
OMAttribute bean = el.getAttribute(new QName("bean"));
if (bean == null) throw new SynapseException("missing bean attribute on "+el.toString());
Added: incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/processors/InProcessor.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/processors/InProcessor.java?rev=348991&view=auto
==============================================================================
--- incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/processors/InProcessor.java (added)
+++ incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/processors/InProcessor.java Fri Nov 25 10:13:33 2005
@@ -0,0 +1,16 @@
+package org.apache.synapse.processors;
+
+
+import org.apache.synapse.SynapseEnvironment;
+import org.apache.synapse.SynapseMessage;
+
+public class InProcessor extends ListProcessor{
+
+ public boolean process(SynapseEnvironment se, SynapseMessage sm) {
+ if (!sm.isResponse()) return super.process(se,sm);
+ return true;
+
+ }
+
+
+}
Added: incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/processors/NeverProcessor.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/processors/NeverProcessor.java?rev=348991&view=auto
==============================================================================
--- incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/processors/NeverProcessor.java (added)
+++ incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/processors/NeverProcessor.java Fri Nov 25 10:13:33 2005
@@ -0,0 +1,14 @@
+package org.apache.synapse.processors;
+
+
+import org.apache.synapse.SynapseEnvironment;
+import org.apache.synapse.SynapseMessage;
+
+public class NeverProcessor extends ListProcessor{
+
+ public boolean process(SynapseEnvironment se, SynapseMessage sm) {
+ return true;
+ }
+
+
+}
Added: incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/processors/OutProcessor.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/processors/OutProcessor.java?rev=348991&view=auto
==============================================================================
--- incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/processors/OutProcessor.java (added)
+++ incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/processors/OutProcessor.java Fri Nov 25 10:13:33 2005
@@ -0,0 +1,16 @@
+package org.apache.synapse.processors;
+
+
+import org.apache.synapse.SynapseEnvironment;
+import org.apache.synapse.SynapseMessage;
+
+public class OutProcessor extends ListProcessor{
+
+ public boolean process(SynapseEnvironment se, SynapseMessage sm) {
+ if (sm.isResponse()) return super.process(se,sm);
+ return true;
+
+ }
+
+
+}
Added: incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/processors/RefProcessor.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/processors/RefProcessor.java?rev=348991&view=auto
==============================================================================
--- incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/processors/RefProcessor.java (added)
+++ incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/processors/RefProcessor.java Fri Nov 25 10:13:33 2005
@@ -0,0 +1,31 @@
+package org.apache.synapse.processors;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.synapse.Processor;
+import org.apache.synapse.SynapseEnvironment;
+import org.apache.synapse.SynapseMessage;
+
+public class RefProcessor extends AbstractProcessor {
+ private Log log = LogFactory.getLog(getClass());
+ private String ref = null;
+
+ public boolean process(SynapseEnvironment se, SynapseMessage sm) {
+ log.debug("process");
+ Processor p = se.lookupProcessor(getRef());
+ if (p==null) log.debug("processor with name "+this.getRef()+" not found");
+ else return p.process(se, sm);
+ return true;
+ }
+
+ public void setRef(String ref) {
+ this.ref = ref;
+ }
+
+ public String getRef() {
+ return ref;
+ }
+
+
+
+}
Added: incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/xml/InProcessorConfigurator.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/xml/InProcessorConfigurator.java?rev=348991&view=auto
==============================================================================
--- incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/xml/InProcessorConfigurator.java (added)
+++ incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/xml/InProcessorConfigurator.java Fri Nov 25 10:13:33 2005
@@ -0,0 +1,29 @@
+package org.apache.synapse.xml;
+
+import javax.xml.namespace.QName;
+
+import org.apache.axis2.om.OMElement;
+import org.apache.synapse.Constants;
+import org.apache.synapse.Processor;
+
+import org.apache.synapse.SynapseEnvironment;
+import org.apache.synapse.processors.InProcessor;
+
+
+
+public class InProcessorConfigurator extends
+ AbstractListProcessorConfigurator {
+ private static final QName IN_Q = new QName(Constants.SYNAPSE_NAMESPACE,
+ "in");
+
+ public QName getTagQName() {
+ return IN_Q;
+ }
+
+ public Processor createProcessor(SynapseEnvironment se, OMElement el) {
+ InProcessor sp = new InProcessor();
+ super.addChildrenAndSetName(se, el, sp);
+ return sp;
+ }
+
+}
Added: incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/xml/NeverProcessorConfigurator.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/xml/NeverProcessorConfigurator.java?rev=348991&view=auto
==============================================================================
--- incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/xml/NeverProcessorConfigurator.java (added)
+++ incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/xml/NeverProcessorConfigurator.java Fri Nov 25 10:13:33 2005
@@ -0,0 +1,27 @@
+package org.apache.synapse.xml;
+
+import javax.xml.namespace.QName;
+
+import org.apache.axis2.om.OMElement;
+import org.apache.synapse.Constants;
+import org.apache.synapse.Processor;
+import org.apache.synapse.SynapseEnvironment;
+import org.apache.synapse.processors.NeverProcessor;
+
+
+public class NeverProcessorConfigurator extends
+ AbstractListProcessorConfigurator {
+ private static final QName NEVER_Q = new QName(Constants.SYNAPSE_NAMESPACE,
+ "never");
+
+ public QName getTagQName() {
+ return NEVER_Q;
+ }
+
+ public Processor createProcessor(SynapseEnvironment se, OMElement el) {
+ NeverProcessor sp = new NeverProcessor();
+ super.addChildrenAndSetName(se, el, sp);
+ return sp;
+ }
+
+}
Added: incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/xml/OutProcessorConfigurator.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/xml/OutProcessorConfigurator.java?rev=348991&view=auto
==============================================================================
--- incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/xml/OutProcessorConfigurator.java (added)
+++ incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/xml/OutProcessorConfigurator.java Fri Nov 25 10:13:33 2005
@@ -0,0 +1,27 @@
+package org.apache.synapse.xml;
+
+import javax.xml.namespace.QName;
+
+import org.apache.axis2.om.OMElement;
+import org.apache.synapse.Constants;
+import org.apache.synapse.Processor;
+import org.apache.synapse.SynapseEnvironment;
+import org.apache.synapse.processors.OutProcessor;
+
+
+public class OutProcessorConfigurator extends
+ AbstractListProcessorConfigurator {
+ private static final QName OUT_Q = new QName(Constants.SYNAPSE_NAMESPACE,
+ "out");
+
+ public QName getTagQName() {
+ return OUT_Q;
+ }
+
+ public Processor createProcessor(SynapseEnvironment se, OMElement el) {
+ OutProcessor sp = new OutProcessor();
+ super.addChildrenAndSetName(se, el, sp);
+ return sp;
+ }
+
+}
Added: incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/xml/RefProcessorConfigurator.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/xml/RefProcessorConfigurator.java?rev=348991&view=auto
==============================================================================
--- incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/xml/RefProcessorConfigurator.java (added)
+++ incubator/synapse/trunk/scratch/prototype3/src/org/apache/synapse/xml/RefProcessorConfigurator.java Fri Nov 25 10:13:33 2005
@@ -0,0 +1,32 @@
+package org.apache.synapse.xml;
+
+import javax.xml.namespace.QName;
+
+import org.apache.axis2.om.OMAttribute;
+import org.apache.axis2.om.OMElement;
+import org.apache.synapse.Constants;
+import org.apache.synapse.Processor;
+import org.apache.synapse.SynapseEnvironment;
+import org.apache.synapse.SynapseException;
+import org.apache.synapse.processors.RefProcessor;
+
+
+public class RefProcessorConfigurator extends
+ AbstractProcessorConfigurator {
+ private static final QName REF_Q = new QName(Constants.SYNAPSE_NAMESPACE,
+ "ref");
+
+ public QName getTagQName() {
+ return REF_Q;
+ }
+
+ public Processor createProcessor(SynapseEnvironment se, OMElement el) {
+ RefProcessor rp = new RefProcessor();
+ super.setNameOnProcessor(se, el, rp);
+ OMAttribute attr = el.getAttribute(new QName("ref"));
+ if (attr==null) throw new SynapseException("<ref> must have attribute ref");
+ rp.setRef(attr.getAttributeValue());
+ return rp;
+ }
+
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: synapse-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: synapse-dev-help@ws.apache.org