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 2006/03/31 10:22:55 UTC
svn commit: r390358 [1/3] - in
/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse: ./ api/
axis2/ mediators/ mediators/base/ mediators/builtin/
mediators/builtin/axis2/ mediators/builtin/xslt/ mediators/conditions/
mediators/rules/ media...
Author: pzf
Date: Fri Mar 31 00:21:31 2006
New Revision: 390358
URL: http://svn.apache.org/viewcvs?rev=390358&view=rev
Log:
Based on the discussion we had (a while back) and vote to refactor the mediators and processors, these are the changes.
Processor is now Deprecated as is ProcessorConfigurator.
Processors have been merged with Mediators. To create a Mediator with your own XML you create a MediatorFactory.
The SynapseEnvironment is now available using the SynapseMessage.getSynapseEnvironment(), so EnvironmentAware is now deprecated too.
All the tests work on my machine, however, I haven't yet done a full system test.
Added:
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/AbstractConditionMediator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/DefineMediator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/InMediator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/ListMediator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/NeverMediator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/OutMediator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/RefDefineMediator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/RefMediator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/StageMediator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/SynapseMediator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/DropMediator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/HeaderMediator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/LogMediator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/SendMediator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/SendNowMediator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/
- copied from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/axis2/
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/AddressingInMediator.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/axis2/AddressingInProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/FaultMediator.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/axis2/FaultProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/SecurityMediator.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/axis2/SecurityProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/xslt/
- copied from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/xslt/
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/xslt/XSLTMediator.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/xslt/XSLTProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/xslt/XSLTMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/xslt/XSLTProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/conditions/
- copied from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/conditions/
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/conditions/DefaultMediator.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/conditions/DefaultProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/conditions/DefaultMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/conditions/DefaultProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/conditions/ExactlyOneMediator.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/conditions/ExactlyOneProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/conditions/ExactlyOneMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/conditions/ExactlyOneProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/rules/
- copied from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/rules/
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/rules/RegexMediator.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/rules/RegexProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/rules/XPathMediator.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/rules/XPathProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/types/
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/types/ClassMediator.java
- copied, changed from r390355, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/mediatortypes/ClassMediator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/mediators/
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/mediators/types/
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/mediators/types/axis2/
- copied from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/mediatortypes/axis2/
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/mediators/types/axis2/ServiceMediator.java
- copied, changed from r390355, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/mediatortypes/axis2/ServiceMediator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/AbstractListMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/AbstractListProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/AbstractMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/AbstractProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/AddressingInMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/AddressingProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/ClassMediatorFactory.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/DefineMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/DefineProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/DropMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/DropProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/FaultMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/FaultProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/HeaderMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/HeaderProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/InMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/InProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/LogMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/LogProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/MediatorFactory.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/MediatorFactoryFinder.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/ProcessorConfiguratorFinder.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/NeverMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/NeverProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/OutMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/OutProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/RefDefineMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/RefDefineProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/RefMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/RefProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/RegexMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/RegexProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/SecurityMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/SecurityProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/SendMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/SendProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/SendNowMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/SendNowProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/ServiceMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/ServiceMediatorProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/StageMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/StageProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/SynapseMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/SynapseProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/XPathMediatorFactory.java
- copied, changed from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/XPathProcessorConfigurator.java
Removed:
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/AddressingInProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/FaultProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/SecurityProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/xslt/XSLTProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/xslt/XSLTProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/conditions/DefaultProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/conditions/DefaultProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/conditions/ExactlyOneProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/conditions/ExactlyOneProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/rules/RegexProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/rules/XPathProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/AbstractProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/DefineProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/InProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/ListProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/NeverProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/OutProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/RefDefineProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/RefProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/StageProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/SynapseProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/DropProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/HeaderProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/LogProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/SendNowProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/SendProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/axis2/
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/xslt/
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/conditions/
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/mediators/types/axis2/ServiceMediatorProcessor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/mediatortypes/ClassMediator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/mediatortypes/axis2/
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/rules/
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/AbstractListProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/AbstractProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/AddressingProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/ClassMediatorProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/DefineProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/DropProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/FaultProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/HeaderProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/InProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/LogProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/NeverProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/OutProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/ProcessorConfiguratorFinder.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/RefDefineProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/RefProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/RegexProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/SecurityProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/SendNowProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/SendProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/ServiceMediatorProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/StageProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/SynapseProcessorConfigurator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/XPathProcessorConfigurator.java
Modified:
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/Processor.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/SynapseEnvironment.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/SynapseMessage.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/api/EnvironmentAware.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/api/Mediator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/api/ResourceUpdateAware.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/Axis2Sender.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/Axis2SynapseEnvironment.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/Axis2SynapseMessage.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/ServiceMediatorMessageReceiver.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/SynapseMessageReceiver.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/AddressingOutMediator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/resources/ResourceHelperFactory.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/resources/ResourceHelperImpl.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/resources/xml/PropertyMediator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/resources/xml/PropertyMediatorFactory.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/resources/xml/ResourceMediator.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/resources/xml/ResourceMediatorFactory.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/AddressingOutMediatorFactory.java
incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/xml/ProcessorConfigurator.java
Modified: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/Processor.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/Processor.java?rev=390358&r1=390357&r2=390358&view=diff
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/Processor.java (original)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/Processor.java Fri Mar 31 00:21:31 2006
@@ -18,6 +18,8 @@
/**
+ * @deprecated
+ *
* Processors are the main extension mechanism for Synapse.
* <p>
* A Processor together with the XML ProcessorConfigurator extends both the synapse.xml
Modified: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/SynapseEnvironment.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/SynapseEnvironment.java?rev=390358&r1=390357&r2=390358&view=diff
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/SynapseEnvironment.java (original)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/SynapseEnvironment.java Fri Mar 31 00:21:31 2006
@@ -15,7 +15,9 @@
*/
package org.apache.synapse;
+import org.apache.synapse.api.Mediator;
import org.apache.synapse.resources.ResourceHelper;
+import org.apache.synapse.resources.xml.ResourceMediator;
import java.util.Map;
import java.util.HashMap;
@@ -25,7 +27,7 @@
*
*
* <p>Common stuff needed to embed Synapse into a given runtime (e.g. Axis2)
- * <p>This interface is used by the processors, and also by EnvironmentAware mediators
+ * <p>This interface is used by the mediators, and also by EnvironmentAware mediators
*
*
*/
@@ -87,7 +89,7 @@
abstract public void injectMessage(SynapseMessage smc);
/*
- * Processors or Mediators that wish to load classes should use the ClassLoader given here
+ * Mediators that wish to load classes should use the ClassLoader given here
*/
abstract public ClassLoader getClassLoader();
@@ -98,34 +100,34 @@
* <p>
* This will send request messages on, and send response messages back to the client
*/
- abstract public void send(SynapseMessage smc, SynapseEnvironment se);
+ abstract public void send(SynapseMessage smc);
/**
* This is used by the references to find a processor with a given name
*
*/
- abstract public Processor lookupProcessor(String name);
+ abstract public Mediator lookupMediator(String name);
/**
* This is how you add a processor to the list of processors. The name which it can be
* retrieved by is the processor.getName()
*/
- abstract public void addProcessor(Processor p);
+ abstract public void addMediator(String name, Mediator m);
/**
* This returns the "Master Processor" which is the root processor for this instance of
* Synapse. Usually this would be the processor derived from <synapse>.
*/
- abstract public Processor getMasterProcessor();
+ abstract public Mediator getMasterMediator();
/**
* This sets the root processor for the engine.
*/
- abstract public void setMasterProcessor(Processor p);
+ abstract public void setMasterMediator(Mediator p);
/**
* This method is responsible for updating resources via simple GET interface.
@@ -133,5 +135,5 @@
abstract public ResourceHelper getResourceHelper();
- abstract public void addResourceProcessor(Processor p);
+ abstract public void addResourceMediator(String name, Mediator p);
}
Modified: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/SynapseMessage.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/SynapseMessage.java?rev=390358&r1=390357&r2=390358&view=diff
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/SynapseMessage.java (original)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/SynapseMessage.java Fri Mar 31 00:21:31 2006
@@ -96,4 +96,7 @@
public void setFaultResponse(boolean b);
public boolean isFaultResponse();
+
+ public SynapseEnvironment getSynapseEnvironment();
+ public void setSynapseEnvironment(SynapseEnvironment env);
}
Modified: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/api/EnvironmentAware.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/api/EnvironmentAware.java?rev=390358&r1=390357&r2=390358&view=diff
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/api/EnvironmentAware.java (original)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/api/EnvironmentAware.java Fri Mar 31 00:21:31 2006
@@ -19,11 +19,11 @@
import org.apache.synapse.SynapseEnvironment;
/**
- *
+ * @deprecated
* <p>API for Mediators to get access to the Synapse Environment
*
*/
-public interface EnvironmentAware {
+public interface EnvironmentAware {
public void setSynapseEnvironment(SynapseEnvironment se);
public void setClassLoader(ClassLoader cl);
Modified: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/api/Mediator.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/api/Mediator.java?rev=390358&r1=390357&r2=390358&view=diff
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/api/Mediator.java (original)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/api/Mediator.java Fri Mar 31 00:21:31 2006
@@ -24,4 +24,6 @@
*/
public interface Mediator {
public boolean mediate(SynapseMessage smc);
+ //public String getName();
+ //public void setName(String name);
}
Modified: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/api/ResourceUpdateAware.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/api/ResourceUpdateAware.java?rev=390358&r1=390357&r2=390358&view=diff
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/api/ResourceUpdateAware.java (original)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/api/ResourceUpdateAware.java Fri Mar 31 00:21:31 2006
@@ -16,4 +16,5 @@
*/
public interface ResourceUpdateAware {
+
}
Modified: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/Axis2Sender.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/Axis2Sender.java?rev=390358&r1=390357&r2=390358&view=diff
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/Axis2Sender.java (original)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/Axis2Sender.java Fri Mar 31 00:21:31 2006
@@ -26,7 +26,6 @@
import org.apache.synapse.Constants;
import org.apache.synapse.SynapseException;
import org.apache.synapse.SynapseMessage;
-import org.apache.synapse.SynapseEnvironment;
import org.apache.axiom.soap.SOAPEnvelope;
import org.apache.axiom.soap.SOAPFactory;
import org.apache.axiom.soap.SOAP12Constants;
@@ -42,7 +41,7 @@
*/
public class Axis2Sender {
- public static void sendOn(SynapseMessage smc, SynapseEnvironment se) {
+ public static void sendOn(SynapseMessage smc) {
try {
@@ -135,7 +134,7 @@
TransportInDescription ti = messageContext.getTransportIn();
outMsgContext.setTransportIn(ti);
- se.injectMessage(new Axis2SynapseMessage(outMsgContext));
+ smc.getSynapseEnvironment().injectMessage(new Axis2SynapseMessage(outMsgContext));
} catch (Exception e) {
throw new SynapseException(e);
Modified: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/Axis2SynapseEnvironment.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/Axis2SynapseEnvironment.java?rev=390358&r1=390357&r2=390358&view=diff
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/Axis2SynapseEnvironment.java (original)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/Axis2SynapseEnvironment.java Fri Mar 31 00:21:31 2006
@@ -22,14 +22,15 @@
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;
-import org.apache.synapse.SynapseException;
+import org.apache.synapse.api.Mediator;
import org.apache.synapse.resources.ResourceHelperFactory;
import org.apache.synapse.resources.ResourceHelper;
+import org.apache.synapse.resources.xml.ResourceMediator;
-import org.apache.synapse.xml.ProcessorConfiguratorFinder;
+import org.apache.synapse.xml.MediatorFactoryFinder;
import org.apache.axiom.om.OMElement;
/**
@@ -40,27 +41,27 @@
*
*/
public class Axis2SynapseEnvironment extends SynapseEnvironment {
- private Processor mainprocessor = null;
+ private Mediator mainmediator = null;
private ClassLoader cl = null;
- private Map processors = new HashMap();
+ private Map mediators = new HashMap();
private Log log = LogFactory.getLog(getClass());
-
+ private ResourceHelperFactory fac = ResourceHelperFactory.newInstance();
//resourceProcessors keeps track of all <resources/>
- private HashMap resourceProcessors = new HashMap();
+ //private HashMap resourceMediators = new HashMap();
public Axis2SynapseEnvironment(OMElement synapseConfiguration,
ClassLoader cl) {
super(null);
this.cl = cl;
if (synapseConfiguration!=null)
- mainprocessor = ProcessorConfiguratorFinder.getProcessor(this, synapseConfiguration);
+ mainmediator = MediatorFactoryFinder.getMediator(this, synapseConfiguration);
}
public void injectMessage(SynapseMessage smc) {
- mainprocessor.process(this, smc);
+ mainmediator.mediate(smc);
}
public ClassLoader getClassLoader() {
@@ -71,49 +72,55 @@
this.cl = cl;
}
- public void send(SynapseMessage sm, SynapseEnvironment se) {
+ public void send(SynapseMessage sm) {
if (sm.isResponse())
Axis2Sender.sendBack(sm);
else
- Axis2Sender.sendOn(sm, se);
+ Axis2Sender.sendOn(sm);
}
- public Processor lookupProcessor(String name) {
- return (Processor) processors.get(name);
+ public Mediator lookupMediator(String name) {
+ return (Mediator) mediators.get(name);
}
- public void addProcessor(Processor p) {
- log.debug("adding processor with name " + p.getName());
- if (processors.containsKey(p.getName()))
- log.warn("name " + p.getName() + "already present");
- processors.put(p.getName(), p);
+ public void addMediator(String name, Mediator m) {
+ log.debug("adding mediator with name " + name);
+ if (mediators.containsKey(name))
+ log.warn("name " + name + "already present");
+ mediators.put(name, m);
}
- public Processor getMasterProcessor() {
- return mainprocessor;
+ public Mediator getMasterMediator() {
+ return mainmediator;
}
- public void setMasterProcessor(Processor p) {
- mainprocessor = p;
+ public void setMasterMediator(Mediator m) {
+ mainmediator = m;
}
// lookup methods for resources handling
- public Processor lookupResourceProcessor(String uriRoot) {
- return (Processor) resourceProcessors.get(uriRoot);
+ public Mediator lookupResourceMediator(String uriRoot) {
+ return (Mediator) fac.getResourceMediator(uriRoot);
}
- public void addResourceProcessor(Processor p) {
- if (resourceProcessors.containsKey(p.getName())) {
+ public void addResourceMediator(String uri, Mediator m) {
+ log.debug("adding "+uri+" with "+m.getClass());
+
+ /*if (resourceMediators.containsKey(uri)) {
throw new SynapseException(
"Uri Root is already exists. Not acceptable");
- }
- resourceProcessors.put(p.getName(), p);
+ }*/
+
+ fac.addResourceMediator(uri, (ResourceMediator)m);
}
public ResourceHelper getResourceHelper() {
- ResourceHelperFactory fac = ResourceHelperFactory.newInstance();
- fac.setResourceProcessorsMap(this.resourceProcessors);
+ //ResourceHelperFactory fac = ResourceHelperFactory.newInstance();
+ //fac.setResourceProcessorsMap(this.resourceMediators);
+ //log.debug("size in env is "+this.resourceMediators.size());
return fac.createResourceHelper();
}
+
+
}
Modified: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/Axis2SynapseMessage.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/Axis2SynapseMessage.java?rev=390358&r1=390357&r2=390358&view=diff
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/Axis2SynapseMessage.java (original)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/Axis2SynapseMessage.java Fri Mar 31 00:21:31 2006
@@ -24,6 +24,7 @@
import org.apache.axis2.addressing.RelatesTo;
import org.apache.axis2.context.MessageContext;
import org.apache.synapse.Constants;
+import org.apache.synapse.SynapseEnvironment;
import org.apache.synapse.SynapseMessage;
import org.apache.axiom.soap.SOAPEnvelope;
@@ -211,5 +212,18 @@
public boolean isFaultResponse() {
return this.faultResponse;
}
+
+ public SynapseEnvironment getSynapseEnvironment() {
+ return Axis2SynapseEnvironmentFinder.getSynapseEnvironment(mc);
+ }
+
+ public void setSynapseEnvironment(SynapseEnvironment env) {
+ mc.setProperty(
+ org.apache.synapse.Constants.MEDIATOR_SYNAPSE_ENV_PROPERTY,env
+ );
+
+ }
+
+
}
Modified: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/ServiceMediatorMessageReceiver.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/ServiceMediatorMessageReceiver.java?rev=390358&r1=390357&r2=390358&view=diff
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/ServiceMediatorMessageReceiver.java (original)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/ServiceMediatorMessageReceiver.java Fri Mar 31 00:21:31 2006
@@ -4,9 +4,7 @@
import org.apache.axis2.context.MessageContext;
import org.apache.axis2.receivers.AbstractMessageReceiver;
import org.apache.synapse.Constants;
-import org.apache.synapse.SynapseEnvironment;
import org.apache.synapse.SynapseMessage;
-import org.apache.synapse.api.EnvironmentAware;
import org.apache.synapse.api.Mediator;
public class ServiceMediatorMessageReceiver extends AbstractMessageReceiver {
@@ -14,7 +12,7 @@
Object obj = makeNewServiceObject(messageContext);
Mediator mediator = (Mediator) obj;
-
+/*
if (EnvironmentAware.class.isAssignableFrom(mediator.getClass())) {
SynapseEnvironment se = (SynapseEnvironment) messageContext
.getProperty(Constants.MEDIATOR_SYNAPSE_ENV_PROPERTY);
@@ -22,6 +20,8 @@
((EnvironmentAware) mediator).setClassLoader(
messageContext.getAxisService().getClassLoader());
}
+
+*/
SynapseMessage smc = new Axis2SynapseMessage(messageContext);
boolean returnValue = mediator.mediate(smc);
messageContext.setProperty(Constants.MEDIATOR_RESPONSE_PROPERTY,
Modified: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/SynapseMessageReceiver.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/SynapseMessageReceiver.java?rev=390358&r1=390357&r2=390358&view=diff
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/SynapseMessageReceiver.java (original)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/axis2/SynapseMessageReceiver.java Fri Mar 31 00:21:31 2006
@@ -41,13 +41,12 @@
.getSynapseEnvironment(mc);
////////////////////////////////////////////////////////////////////////
// SynapseEnvironment is set as a property in MessageContext. This is due
- // use we can expect in ServiceMeidatorProcessor and many extensions yet to come
+ // use we can expect in ServiceMediatorProcessor and many extensions yet to come
// So it a mediator uses EnvironmentAware, that mediator will be injected with the correct environment
- mc.setProperty(
- org.apache.synapse.Constants.MEDIATOR_SYNAPSE_ENV_PROPERTY,
- env);
+
////////////////////////////////////////////////////////////////////////
SynapseMessage smc = new Axis2SynapseMessage(mc);
+ smc.setSynapseEnvironment(env);
env.injectMessage(smc);
///////////////////////////////////////////////////////////////////////
Added: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/AbstractConditionMediator.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/AbstractConditionMediator.java?rev=390358&view=auto
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/AbstractConditionMediator.java (added)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/AbstractConditionMediator.java Fri Mar 31 00:21:31 2006
@@ -0,0 +1,51 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed 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.synapse.mediators.base;
+
+
+
+
+import org.apache.synapse.SynapseMessage;
+import org.apache.synapse.SynapseMessageConstants;
+
+
+/**
+ * This is a base type for "conditional" mediators. Any mediator that is used in "only once"
+ * processing should be an extension of this. This makes sure that the matched property gets set properly
+ *
+ *
+ */
+public abstract class AbstractConditionMediator extends ListMediator {
+
+ //private Log log = LogFactory.getLog(getClass());
+
+ public boolean mediate(SynapseMessage smc) {
+ if (this.test(smc)) {
+ smc.setProperty(SynapseMessageConstants.MATCHED,Boolean.TRUE);
+ return super.mediate(smc);
+ }
+ else
+ {
+ smc.setProperty(SynapseMessageConstants.MATCHED,Boolean.FALSE);
+ return true;
+ }
+ }
+ public abstract boolean test(SynapseMessage sm);
+
+
+
+}
Added: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/DefineMediator.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/DefineMediator.java?rev=390358&view=auto
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/DefineMediator.java (added)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/DefineMediator.java Fri Mar 31 00:21:31 2006
@@ -0,0 +1,43 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed 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.synapse.mediators.base;
+
+import org.apache.synapse.SynapseMessage;
+
+/**
+ *
+ */
+public class DefineMediator extends ListMediator {
+
+ public boolean mediate(SynapseMessage sm) {
+ return true;
+ }
+
+ /*
+ The Processor.process() is common to every one. Define Processor is a unique
+ mediator that is not run in-line. It should always reference by some entity. This
+ Entity is "<refdefine/>. <refdefine/> has the @ref which will reference to the
+ <define/>.
+
+ The Following method processRef(SynapseEnvironment se, SynapseMessage sm) will
+ allow to reference the <define/> process and, will not allow the <define/> to be a inline
+ process either.
+ */
+
+ public boolean mediateRef(SynapseMessage sm) {
+ return super.mediate(sm);
+ }
+}
Added: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/InMediator.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/InMediator.java?rev=390358&view=auto
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/InMediator.java (added)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/InMediator.java Fri Mar 31 00:21:31 2006
@@ -0,0 +1,37 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed 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.synapse.mediators.base;
+
+
+import org.apache.synapse.SynapseMessage;
+
+/**
+ *
+ *
+ * Only processes if this is not a response
+ *
+ */
+public class InMediator extends ListMediator{
+
+ public boolean mediate(SynapseMessage sm) {
+ if (!sm.isResponse()) return super.mediate(sm);
+ return true;
+
+ }
+
+
+}
Added: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/ListMediator.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/ListMediator.java?rev=390358&view=auto
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/ListMediator.java (added)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/ListMediator.java Fri Mar 31 00:21:31 2006
@@ -0,0 +1,71 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed 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.synapse.mediators.base;
+
+import java.util.Iterator;
+
+import java.util.List;
+
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.synapse.api.Mediator;
+import org.apache.synapse.SynapseMessage;
+
+
+/**
+ *
+ * stages, mediations that it has as subelements It is a way of grouping
+ * stuff.
+ *
+ */
+public abstract class ListMediator implements Mediator {
+
+ private Log log = LogFactory.getLog(getClass());
+
+ protected List mediators = null;
+
+ public boolean mediate(SynapseMessage smc) {
+ log.debug("mediate()");
+ if (mediators == null) {
+ log.info("mediate called on empty mediator list");
+ return true;
+ }
+ Iterator it = mediators.iterator();
+ while (it.hasNext()) {
+ Mediator m = (Mediator) it.next();
+ log.debug(m.getClass());
+ if (!m.mediate(smc))
+ return false;
+ }
+ return true;
+ }
+
+ public void setList(List m) {
+ log.debug("setting list");
+ Iterator it = m.iterator();
+ while (it.hasNext()) {
+ Mediator x = (Mediator)it.next();
+ log.debug(x.getClass());
+ }
+ mediators = m;
+ }
+ public List getList() {
+ return mediators;
+ }
+
+}
Added: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/NeverMediator.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/NeverMediator.java?rev=390358&view=auto
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/NeverMediator.java (added)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/NeverMediator.java Fri Mar 31 00:21:31 2006
@@ -0,0 +1,34 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed 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.synapse.mediators.base;
+
+
+import org.apache.synapse.SynapseMessage;
+
+/**
+ *
+ * This never executes its children. Used as a holder (for references)
+ *
+ */
+public class NeverMediator extends ListMediator {
+
+ public boolean mediate(SynapseMessage sm) {
+ return true;
+ }
+
+
+}
Added: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/OutMediator.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/OutMediator.java?rev=390358&view=auto
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/OutMediator.java (added)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/OutMediator.java Fri Mar 31 00:21:31 2006
@@ -0,0 +1,34 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed 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.synapse.mediators.base;
+
+import org.apache.synapse.SynapseMessage;
+
+/**
+ * <p>
+ * This only executes on response messages
+ *
+ */
+public class OutMediator extends ListMediator{
+
+ public boolean mediate(SynapseMessage sm) {
+ if (sm.isResponse()) return super.mediate(sm);
+ return true;
+ }
+
+
+}
Added: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/RefDefineMediator.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/RefDefineMediator.java?rev=390358&view=auto
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/RefDefineMediator.java (added)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/RefDefineMediator.java Fri Mar 31 00:21:31 2006
@@ -0,0 +1,50 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed 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.synapse.mediators.base;
+
+import org.apache.synapse.SynapseMessage;
+import org.apache.synapse.api.Mediator;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+/**
+ * Processor that reference to <refdefine/>
+ */
+public class RefDefineMediator implements Mediator {
+ private Log log = LogFactory.getLog(getClass());
+ private String refDefine = null;
+
+ public boolean mediate(SynapseMessage sm) {
+ log.debug("RefDfineProcessor-Process");
+ Mediator m = sm.getSynapseEnvironment().lookupMediator(getRefDefine());
+ if (m==null) log.debug("mediator with name "+this.getRefDefine()+" not found");
+ else if (m instanceof DefineMediator) {
+ DefineMediator defm = (DefineMediator)m;
+ return defm.mediateRef(sm);
+ }
+ return true;
+ }
+
+ public void setRefDefine(String refDefine) {
+ this.refDefine = refDefine;
+ }
+
+ public String getRefDefine() {
+ return this.refDefine;
+ }
+
+}
Added: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/RefMediator.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/RefMediator.java?rev=390358&view=auto
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/RefMediator.java (added)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/RefMediator.java Fri Mar 31 00:21:31 2006
@@ -0,0 +1,52 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed 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.synapse.mediators.base;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.synapse.SynapseMessage;
+import org.apache.synapse.api.Mediator;
+
+/**
+ *
+ *
+ * Calls another processor which is referred to by the Ref property.
+ *
+ */
+public class RefMediator implements Mediator {
+ private Log log = LogFactory.getLog(getClass());
+ private String ref = null;
+
+ public boolean mediate(SynapseMessage sm) {
+ log.debug("mediate");
+ Mediator m = sm.getSynapseEnvironment().lookupMediator(getRef());
+ if (m==null) log.debug("mediator with name "+this.getRef()+" not found");
+ else return m.mediate(sm);
+ return true;
+ }
+
+ public void setRef(String ref) {
+ this.ref = ref;
+ }
+
+ public String getRef() {
+ return ref;
+ }
+
+
+
+}
Added: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/StageMediator.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/StageMediator.java?rev=390358&view=auto
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/StageMediator.java (added)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/StageMediator.java Fri Mar 31 00:21:31 2006
@@ -0,0 +1,26 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed 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.synapse.mediators.base;
+
+
+/**
+ *
+ *
+ *
+ */
+public class StageMediator extends ListMediator {
+}
Added: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/SynapseMediator.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/SynapseMediator.java?rev=390358&view=auto
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/SynapseMediator.java (added)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/base/SynapseMediator.java Fri Mar 31 00:21:31 2006
@@ -0,0 +1,27 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed 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.synapse.mediators.base;
+
+/**
+ *
+ *
+ * This implements the main processor. Delegates to ListProcessor
+ * Here in case we need the main <synapse> to do anything special
+ *
+ */
+public class SynapseMediator extends ListMediator {
+}
Added: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/DropMediator.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/DropMediator.java?rev=390358&view=auto
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/DropMediator.java (added)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/DropMediator.java Fri Mar 31 00:21:31 2006
@@ -0,0 +1,36 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed 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.synapse.mediators.builtin;
+
+import org.apache.synapse.api.Mediator;
+
+import org.apache.synapse.SynapseMessage;
+
+/**
+ * Implementaion of <drop/>
+ */
+public class DropMediator implements Mediator {
+
+ public boolean mediate(SynapseMessage sm) {
+ if (sm.getTo() == null) {
+ return false;
+ }else{
+ sm.setTo(null);
+ return false;
+ }
+ }
+}
Added: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/HeaderMediator.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/HeaderMediator.java?rev=390358&view=auto
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/HeaderMediator.java (added)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/HeaderMediator.java Fri Mar 31 00:21:31 2006
@@ -0,0 +1,61 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed 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.synapse.mediators.builtin;
+
+import org.apache.synapse.HeaderType;
+import org.apache.synapse.SynapseMessage;
+
+import org.apache.synapse.api.Mediator;
+
+
+/**
+ *
+ * @see org.apache.synapse.HeaderType
+ * <p> Sets aspects of the header to new values.
+ * Uses HeaderType to set header values
+ *
+ */
+public class HeaderMediator implements Mediator{
+
+ private HeaderType headerType = new HeaderType();
+
+ private String value = null;
+
+ public void setHeaderType(String ht) {
+ headerType.setHeaderType(ht);
+ }
+
+ public String getHeaderType() {
+ return headerType.getHeaderType();
+ }
+
+ public boolean mediate(SynapseMessage sm) {
+
+ headerType.setHeader(sm, getValue());
+ return true;
+ }
+
+ public void setValue(String value) {
+ this.value = value;
+ }
+
+ public String getValue() {
+ return value;
+ }
+
+}
Added: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/LogMediator.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/LogMediator.java?rev=390358&view=auto
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/LogMediator.java (added)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/LogMediator.java Fri Mar 31 00:21:31 2006
@@ -0,0 +1,55 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed 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.synapse.mediators.builtin;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+import org.apache.synapse.SynapseMessage;
+
+import org.apache.synapse.api.Mediator;
+
+
+/**
+ *
+ * <p>
+ * Logs the message using commons logging
+ *
+ * <p>
+ * TODO make configurable - short or detailed logs
+ *
+ */
+public class LogMediator implements Mediator {
+
+ private Log log = LogFactory.getLog(getClass());
+
+ public boolean mediate(SynapseMessage smc) {
+ log.info("---------------------------------------");
+ if (smc.getTo() != null)
+ log.info("To: " + smc.getTo().getAddress());
+ if (smc.getFrom() != null)
+ log.info("From: " + smc.getFrom().getAddress());
+ if (smc.getReplyTo() != null)
+ log.info("ReplyTo: " + smc.getReplyTo().getAddress());
+ if (smc.getEnvelope() != null)
+ log.info("Envelope: " + smc.getEnvelope().toString());
+ log.info("---------------------------------------");
+ return true;
+ }
+
+
+}
Added: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/SendMediator.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/SendMediator.java?rev=390358&view=auto
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/SendMediator.java (added)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/SendMediator.java Fri Mar 31 00:21:31 2006
@@ -0,0 +1,46 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed 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.synapse.mediators.builtin;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.synapse.api.Mediator;
+import org.apache.synapse.SynapseMessage;
+
+/**
+ *
+ * <p>
+ *
+ * This sends the message on (or back)
+ *
+ */
+public class SendMediator implements Mediator {
+
+
+ private Log log = LogFactory.getLog(getClass());
+
+
+ public boolean mediate(SynapseMessage smc) {
+ log.debug("mediate");
+ smc.getSynapseEnvironment().send(smc);
+ return false;
+
+ }
+
+
+
+}
Added: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/SendNowMediator.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/SendNowMediator.java?rev=390358&view=auto
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/SendNowMediator.java (added)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/SendNowMediator.java Fri Mar 31 00:21:31 2006
@@ -0,0 +1,168 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed 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.synapse.mediators.builtin;
+
+import org.apache.synapse.SynapseMessage;
+import org.apache.synapse.SynapseException;
+import org.apache.synapse.api.Mediator;
+import org.apache.synapse.axis2.Axis2SynapseMessage;
+import org.apache.synapse.axis2.Axis2FlexibleMEPClient;
+import org.apache.synapse.axis2.DynamicAxisOperation;
+import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.context.ConfigurationContext;
+import org.apache.axis2.context.ServiceGroupContext;
+import org.apache.axis2.context.ServiceContext;
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.transport.TransportUtils;
+import org.apache.axis2.client.OperationClient;
+import org.apache.axis2.client.Options;
+import org.apache.axis2.util.UUIDGenerator;
+import org.apache.axis2.description.AxisService;
+import org.apache.axis2.description.AxisOperation;
+import org.apache.axis2.description.TransportInDescription;
+import org.apache.axis2.description.AxisServiceGroup;
+import org.apache.axis2.deployment.util.PhasesInfo;
+import org.apache.axis2.engine.AxisConfiguration;
+import org.apache.axis2.engine.AxisEngine;
+import org.apache.wsdl.WSDLConstants;
+import org.apache.axiom.soap.SOAPEnvelope;
+
+import javax.xml.namespace.QName;
+
+/**
+ * Implementaion of <sendnow/>
+ */
+public class SendNowMediator implements Mediator {
+ public boolean mediate( SynapseMessage sm) {
+ MessageContext mc = ((Axis2SynapseMessage)sm).getMessageContext();
+
+ try {
+ MessageContext response = send(mc);
+ if (response.getProperty(MessageContext.TRANSPORT_IN) !=null) {
+ SOAPEnvelope resenvelope = TransportUtils.createSOAPMessage(
+ response, mc.getEnvelope().getNamespace()
+ .getName());
+
+ response.setEnvelope(resenvelope);
+ outMessageSerialization(response,mc,sm);
+ }
+
+
+ } catch (AxisFault axisFault) {
+ throw new SynapseException(axisFault);
+ }
+ // this will stop processing message and what User
+ return false;
+ }
+
+ public MessageContext send(MessageContext smc) throws AxisFault {
+ ConfigurationContext cc = smc.getConfigurationContext();
+ AxisConfiguration ac = cc.getAxisConfiguration();
+ PhasesInfo phasesInfo = ac.getPhasesInfo();
+
+ // setting operation default chains
+ if (ac.getService("__ANONYMOUS_SERVICE__") == null) {
+ DynamicAxisOperation operation = new DynamicAxisOperation(new QName(
+ "__DYNAMIC_OPERATION__"));
+ AxisService axisAnonymousService =
+ new AxisService("__ANONYMOUS_SERVICE__");
+ axisAnonymousService.addOperation(operation);
+ ac.addService(axisAnonymousService);
+ phasesInfo.setOperationPhases(operation);
+ }
+ ServiceGroupContext sgc = new ServiceGroupContext(cc,
+ (AxisServiceGroup)ac.getService("__ANONYMOUS_SERVICE__").getParent());
+ ServiceContext sc =
+ sgc.getServiceContext(new AxisService("__ANONYMOUS_SERVICE__"));
+
+ MessageContext mc = new MessageContext();
+ mc.setConfigurationContext(sc.getConfigurationContext());
+ ///////////////////////////////////////////////////////////////////////
+ // filtering properties
+ if (smc.getSoapAction() != null)
+ mc.setSoapAction(smc.getSoapAction());
+ if (smc.getWSAAction() != null)
+ mc.setWSAAction(smc.getWSAAction());
+ if (smc.getFrom() != null)
+ mc.setFrom(smc.getFrom());
+ if (smc.getMessageID() != null)
+ mc.setMessageID(smc.getMessageID());
+ else
+ mc.setMessageID(String.valueOf("uuid:"
+ + UUIDGenerator.getUUID()));
+ if (smc.getReplyTo() != null)
+ mc.setReplyTo(smc.getReplyTo());
+ if (smc.getRelatesTo() != null)
+ mc.setRelatesTo(smc.getRelatesTo());
+ if (smc.getTo() != null) {
+ mc.setTo(smc.getTo());
+ } else {
+ throw new AxisFault(
+ "To canno't be null, if null Synapse can't infer the transport");
+ }
+ if (smc.isDoingREST()) {
+ mc.setDoingREST(true);
+ }
+ mc.setEnvelope(Axis2FlexibleMEPClient.outEnvelopeConfiguration(smc));
+
+ AxisOperation axisAnonymousOperation =
+ ac.getService("__ANONYMOUS_SERVICE__")
+ .getOperation(new QName("__DYNAMIC_OPERATION__"));
+
+ Options options = new Options();
+ OperationClient mepClient =
+ axisAnonymousOperation.createClient(sc,options);
+
+ mepClient.addMessageContext(mc);
+ mepClient.execute(true);
+ MessageContext response = mepClient
+ .getMessageContext(WSDLConstants.MESSAGE_LABEL_IN_VALUE);
+
+
+ response.setProperty(MessageContext.TRANSPORT_OUT,
+ smc.getProperty(MessageContext.TRANSPORT_OUT));
+ response.setProperty(org.apache.axis2.Constants.OUT_TRANSPORT_INFO,
+ smc.getProperty(
+ org.apache.axis2.Constants.OUT_TRANSPORT_INFO));
+
+ // If request is REST we assume the response is REST, so set the
+ // variable
+ response.setDoingREST(smc.isDoingREST());
+
+ return response;
+ }
+
+ private void outMessageSerialization(MessageContext mcn,MessageContext mco,SynapseMessage sm) throws AxisFault {
+
+ // copying important configuration stuff
+ sm.setResponse(true);
+ // as agreed upone
+ mcn.setTo(null);
+ Object os = mco
+ .getProperty(MessageContext.TRANSPORT_OUT);
+ mcn.setProperty(MessageContext.TRANSPORT_OUT, os);
+ TransportInDescription ti = mco.getTransportIn();
+ mcn.setTransportIn(ti);
+ mcn.setServerSide(true);
+
+ AxisEngine ae = new AxisEngine(mco.getConfigurationContext());
+ ae.send(mcn);
+
+
+ }
+
+}
Copied: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/AddressingInMediator.java (from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/axis2/AddressingInProcessor.java)
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/AddressingInMediator.java?p2=incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/AddressingInMediator.java&p1=incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/axis2/AddressingInProcessor.java&r1=389703&r2=390358&rev=390358&view=diff
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/axis2/AddressingInProcessor.java (original)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/AddressingInMediator.java Fri Mar 31 00:21:31 2006
@@ -14,11 +14,15 @@
* limitations under the License.
*/
-package org.apache.synapse.processors.builtin.axis2;
+package org.apache.synapse.mediators.builtin.axis2;
import org.apache.axis2.AxisFault;
-import org.apache.axis2.context.*;
+import org.apache.axis2.context.ConfigurationContext;
+import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.context.OperationContext;
+import org.apache.axis2.context.OperationContextFactory;
+import org.apache.axis2.context.ServiceContext;
import org.apache.axis2.description.AxisOperation;
import org.apache.axis2.description.AxisService;
import org.apache.axis2.description.AxisModule;
@@ -31,15 +35,17 @@
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.synapse.Constants;
-import org.apache.synapse.SynapseEnvironment;
import org.apache.synapse.SynapseException;
import org.apache.synapse.SynapseMessage;
+import org.apache.synapse.api.Mediator;
import org.apache.synapse.axis2.Axis2SynapseMessage;
-import org.apache.synapse.processors.AbstractProcessor;
+
+
+
import javax.xml.namespace.QName;
@@ -49,11 +55,11 @@
* This class turns on the addressing module and then calls an empty
* service There's probably a better way but this should work!
*/
-public class AddressingInProcessor extends AbstractProcessor {
+public class AddressingInMediator implements Mediator{
private Log log = LogFactory.getLog(getClass());
- public boolean process(SynapseEnvironment se, SynapseMessage smc) {
+ public boolean mediate(SynapseMessage smc) {
log.debug("Processing __AddressingInHandler__");
try {
MessageContext mc = ((Axis2SynapseMessage)smc).getMessageContext();
Modified: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/AddressingOutMediator.java
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/AddressingOutMediator.java?rev=390358&r1=389703&r2=390358&view=diff
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/AddressingOutMediator.java (original)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/AddressingOutMediator.java Fri Mar 31 00:21:31 2006
@@ -1,7 +1,8 @@
-package org.apache.synapse.processors.builtin.axis2;
+package org.apache.synapse.mediators.builtin.axis2;
+
+import org.apache.synapse.api.Mediator;
+
-import org.apache.synapse.processors.AbstractProcessor;
-import org.apache.synapse.SynapseEnvironment;
import org.apache.synapse.SynapseMessage;
import org.apache.synapse.Constants;
/*
@@ -20,8 +21,8 @@
* limitations under the License.
*/
-public class AddressingOutMediator extends AbstractProcessor {
- public boolean process(SynapseEnvironment se, SynapseMessage sm) {
+public class AddressingOutMediator implements Mediator {
+ public boolean mediate(SynapseMessage sm) {
// engage addressing outhandler in the out bound message.
sm.setProperty(Constants.ENGAGE_ADDRESSING_OUT_BOUND_MESSAGE, Boolean.TRUE);
return true;
Copied: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/FaultMediator.java (from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/axis2/FaultProcessor.java)
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/FaultMediator.java?p2=incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/FaultMediator.java&p1=incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/axis2/FaultProcessor.java&r1=389703&r2=390358&rev=390358&view=diff
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/axis2/FaultProcessor.java (original)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/FaultMediator.java Fri Mar 31 00:21:31 2006
@@ -14,68 +14,61 @@
* limitations under the License.
*/
-package org.apache.synapse.processors.builtin.axis2;
-
+package org.apache.synapse.mediators.builtin.axis2;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
-import org.apache.synapse.SynapseEnvironment;
import org.apache.synapse.SynapseException;
import org.apache.synapse.SynapseMessage;
-
-import org.apache.synapse.processors.AbstractProcessor;
+import org.apache.synapse.api.Mediator;
import org.apache.axiom.soap.SOAPEnvelope;
import org.apache.axiom.soap.SOAP12Constants;
import org.apache.axiom.soap.SOAPFactory;
import org.apache.axiom.om.OMAbstractFactory;
import org.apache.axiom.om.OMDocument;
-
/**
- * <p/>
- * This returns a fault in response to this message
+ * <p/> This returns a fault in response to this message
*/
-public class FaultProcessor extends AbstractProcessor {
-
- private Log log = LogFactory.getLog(getClass());
-
- public boolean process(SynapseEnvironment se, SynapseMessage smc) {
- log.debug("process");
+public class FaultMediator implements Mediator{
- SOAPEnvelope envelop = smc.getEnvelope();
- SOAPFactory factory;
- if (envelop != null) {
- if (envelop.getNamespace().getName()
- .equals(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI)) {
- factory = OMAbstractFactory.getSOAP12Factory();
- } else {
- factory = OMAbstractFactory.getSOAP11Factory();
- }
-
- } else {
- factory = OMAbstractFactory.getSOAP11Factory();
- }
- try {
- OMDocument soapFaultDocument = factory.createOMDocument();
- SOAPEnvelope faultEnvelope = factory.getDefaultFaultEnvelope();
- soapFaultDocument.addChild(faultEnvelope);
- smc.setEnvelope(faultEnvelope);
- } catch (Exception e) {
- throw new SynapseException(e);
- }
- smc.setResponse(true);
-
- //Flipping the headers
- EndpointReference tempEPR = smc.getTo();
- smc.setTo(smc.getReplyTo());
- smc.setReplyTo(tempEPR);
+ private Log log = LogFactory.getLog(getClass());
- se.injectMessage(smc);
+ public boolean mediate(SynapseMessage smc) {
+ log.debug("process");
+ SOAPEnvelope envelop = smc.getEnvelope();
+ SOAPFactory factory;
+ if (envelop != null) {
+ if (envelop.getNamespace().getName().equals(
+ SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI)) {
+ factory = OMAbstractFactory.getSOAP12Factory();
+ } else {
+ factory = OMAbstractFactory.getSOAP11Factory();
+ }
+
+ } else {
+ factory = OMAbstractFactory.getSOAP11Factory();
+ }
+ try {
+ OMDocument soapFaultDocument = factory.createOMDocument();
+ SOAPEnvelope faultEnvelope = factory.getDefaultFaultEnvelope();
+ soapFaultDocument.addChild(faultEnvelope);
+ smc.setEnvelope(faultEnvelope);
+ } catch (Exception e) {
+ throw new SynapseException(e);
+ }
+ smc.setResponse(true);
+
+ // Flipping the headers
+ EndpointReference tempEPR = smc.getTo();
+ smc.setTo(smc.getReplyTo());
+ smc.setReplyTo(tempEPR);
- return false;
- }
+ smc.getSynapseEnvironment().injectMessage(smc);
+ return false;
+ }
}
Copied: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/SecurityMediator.java (from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/axis2/SecurityProcessor.java)
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/SecurityMediator.java?p2=incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/SecurityMediator.java&p1=incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/axis2/SecurityProcessor.java&r1=389703&r2=390358&rev=390358&view=diff
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/axis2/SecurityProcessor.java (original)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/axis2/SecurityMediator.java Fri Mar 31 00:21:31 2006
@@ -1,14 +1,18 @@
-package org.apache.synapse.processors.builtin.axis2;
+package org.apache.synapse.mediators.builtin.axis2;
+
-import org.apache.synapse.processors.AbstractProcessor;
-import org.apache.synapse.SynapseEnvironment;
import org.apache.synapse.SynapseMessage;
import org.apache.synapse.Constants;
import org.apache.synapse.SynapseException;
+import org.apache.synapse.api.Mediator;
import org.apache.synapse.axis2.Axis2SynapseMessage;
-import org.apache.axis2.context.*;
import org.apache.axis2.engine.AxisConfiguration;
import org.apache.axis2.engine.AxisEngine;
+import org.apache.axis2.context.ConfigurationContext;
+import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.context.OperationContext;
+import org.apache.axis2.context.OperationContextFactory;
+import org.apache.axis2.context.ServiceContext;
import org.apache.axis2.description.AxisService;
import org.apache.axis2.description.AxisOperation;
import org.apache.axis2.util.Utils;
@@ -34,10 +38,10 @@
*
*/
-public class SecurityProcessor extends AbstractProcessor {
+public class SecurityMediator implements Mediator {
private Log log = LogFactory.getLog(getClass());
- public boolean process(SynapseEnvironment se, SynapseMessage sm) {
+ public boolean mediate(SynapseMessage sm) {
log.debug("process");
try {
MessageContext mc = ((Axis2SynapseMessage) sm)
Copied: incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/xslt/XSLTMediator.java (from r389703, incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/xslt/XSLTProcessor.java)
URL: http://svn.apache.org/viewcvs/incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/xslt/XSLTMediator.java?p2=incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/xslt/XSLTMediator.java&p1=incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/xslt/XSLTProcessor.java&r1=389703&r2=390358&rev=390358&view=diff
==============================================================================
--- incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/processors/builtin/xslt/XSLTProcessor.java (original)
+++ incubator/synapse/trunk/java/modules/core/src/org/apache/synapse/mediators/builtin/xslt/XSLTMediator.java Fri Mar 31 00:21:31 2006
@@ -1,4 +1,4 @@
-package org.apache.synapse.processors.builtin.xslt;
+package org.apache.synapse.mediators.builtin.xslt;
@@ -15,30 +15,29 @@
import javax.xml.transform.stream.StreamResult;
import javax.xml.transform.stream.StreamSource;
-import org.apache.synapse.SynapseEnvironment;
import org.apache.synapse.SynapseException;
import org.apache.synapse.SynapseMessage;
-import org.apache.synapse.processors.AbstractProcessor;
+import org.apache.synapse.api.Mediator;
import org.apache.axiom.om.impl.builder.StAXOMBuilder;
import org.apache.axiom.om.OMElement;
import org.apache.axiom.om.OMAbstractFactory;
/**
*
- * @see org.apache.synapse.processors.builtin.xslt.XSLTProcessorConfigurator
+ * @see org.apache.synapse.mediators.base.builtin.xslt.XSLTProcessorConfigurator
* <p> This class is the class that transforms messages using XSLT.
*
*
*/
-public class XSLTProcessor extends AbstractProcessor {
+public class XSLTMediator implements Mediator {
private Transformer tran = null;
private boolean isBody = false;
- public boolean process(SynapseEnvironment se, SynapseMessage smc) {
+ public boolean mediate(SynapseMessage smc) {
ByteArrayOutputStream baos = new ByteArrayOutputStream();
XMLStreamWriter xsw;
try {
---------------------------------------------------------------------
To unsubscribe, e-mail: synapse-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: synapse-dev-help@ws.apache.org