You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@synapse.apache.org by ru...@apache.org on 2007/12/14 05:48:05 UTC
svn commit: r604103 - in
/webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse:
config/xml/POJOCommandMediatorSerializationTest.java
mediators/ext/POJOCommandMediatorTest.java
mediators/ext/POJOCommandTestImplementedMediator.java
Author: ruwan
Date: Thu Dec 13 20:48:05 2007
New Revision: 604103
URL: http://svn.apache.org/viewvc?rev=604103&view=rev
Log:
Test cases for the new POJOCommand syntax
Modified:
webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/POJOCommandMediatorSerializationTest.java
webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/mediators/ext/POJOCommandMediatorTest.java
webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/mediators/ext/POJOCommandTestImplementedMediator.java
Modified: webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/POJOCommandMediatorSerializationTest.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/POJOCommandMediatorSerializationTest.java?rev=604103&r1=604102&r2=604103&view=diff
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/POJOCommandMediatorSerializationTest.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/config/xml/POJOCommandMediatorSerializationTest.java Thu Dec 13 20:48:05 2007
@@ -50,7 +50,7 @@
public void testPOJOCommandNotImplementedMediatorWithPropertySerialization() throws Exception {
String inputXml = "<pojoCommand xmlns=\"http://ws.apache.org/ns/synapse\" " +
"name=\"org.apache.synapse.mediators.ext.POJOCommandTestMediator\">" +
- "<property name=\"testProp\" expression=\"fn:concat('XPATH ', 'FUNC')\" action=\"set\"/></pojoCommand>";
+ "<property name=\"testProp\" expression=\"fn:concat('XPATH ', 'FUNC')\" action=\"ReadMessage\"/></pojoCommand>";
assertTrue(serialization(inputXml, pojoCommandMediatorFactory, pojoCommandMediatorSerializer));
assertTrue(serialization(inputXml, pojoCommandMediatorSerializer));
}
@@ -58,7 +58,7 @@
public void testPOJOCommandMediatorImplementedWithPropertySerialization() throws Exception {
String inputXml = "<pojoCommand xmlns=\"http://ws.apache.org/ns/synapse\" " +
"name=\"org.apache.synapse.mediators.ext.POJOCommandTestImplementedMediator\">" +
- "<property name=\"testProp\" expression=\"fn:concat('XPATH ', 'FUNC')\" action=\"set\"/></pojoCommand>";
+ "<property name=\"testProp\" expression=\"fn:concat('XPATH ', 'FUNC')\" action=\"UpdateMessage\"/></pojoCommand>";
assertTrue(serialization(inputXml, pojoCommandMediatorFactory, pojoCommandMediatorSerializer));
assertTrue(serialization(inputXml, pojoCommandMediatorSerializer));
}
@@ -66,7 +66,7 @@
public void testPOJOCommandMediatorWithStaticPropertySerialization() throws Exception {
String inputXml = "<pojoCommand xmlns=\"http://ws.apache.org/ns/synapse\" " +
"name=\"org.apache.synapse.mediators.ext.POJOCommandTestMediator\">" +
- "<property name=\"testProp\" value=\"Test Property\" action=\"set\"/></pojoCommand>";
+ "<property name=\"testProp\" value=\"Test Property\"/></pojoCommand>";
assertTrue(serialization(inputXml, pojoCommandMediatorFactory, pojoCommandMediatorSerializer));
assertTrue(serialization(inputXml, pojoCommandMediatorSerializer));
}
@@ -74,7 +74,7 @@
public void testPOJOCommandMediatorWithMessagePropertySerialization() throws Exception {
String inputXml = "<pojoCommand xmlns=\"http://ws.apache.org/ns/synapse\" " +
"name=\"org.apache.synapse.mediators.ext.POJOCommandTestMediator\">" +
- "<property name=\"testProp\" expression=\"fn:concat('XPATH ', 'FUNC')\" action=\"get\"/></pojoCommand>";
+ "<property name=\"testProp\" expression=\"fn:concat('XPATH ', 'FUNC')\" action=\"ReadAndUpdateMessage\"/></pojoCommand>";
assertTrue(serialization(inputXml, pojoCommandMediatorFactory, pojoCommandMediatorSerializer));
assertTrue(serialization(inputXml, pojoCommandMediatorSerializer));
}
@@ -82,7 +82,39 @@
public void testPOJOCommandMediatorWithContextPropertySerialization() throws Exception {
String inputXml = "<pojoCommand xmlns=\"http://ws.apache.org/ns/synapse\" " +
"name=\"org.apache.synapse.mediators.ext.POJOCommandTestMediator\">" +
- "<property name=\"testProp\" value=\"Test Property\" action=\"get\"/></pojoCommand>";
+ "<property name=\"testProp\" value=\"Test Property\" context-name=\"prop\"/></pojoCommand>";
+ assertTrue(serialization(inputXml, pojoCommandMediatorFactory, pojoCommandMediatorSerializer));
+ assertTrue(serialization(inputXml, pojoCommandMediatorSerializer));
+ }
+
+ public void testPOJOCommandMediatorWithContextMessagePropertySerialization() throws Exception {
+ String inputXml = "<pojoCommand xmlns=\"http://ws.apache.org/ns/synapse\" " +
+ "name=\"org.apache.synapse.mediators.ext.POJOCommandTestMediator\">" +
+ "<property name=\"testProp\" expression=\"fn:concat('XPATH ', 'FUNC')\" context-name=\"prop\" action=\"ReadMessage\"/></pojoCommand>";
+ assertTrue(serialization(inputXml, pojoCommandMediatorFactory, pojoCommandMediatorSerializer));
+ assertTrue(serialization(inputXml, pojoCommandMediatorSerializer));
+ }
+
+ public void testPOJOCommandMediatorWithMessage$ContextPropertySerialization() throws Exception {
+ String inputXml = "<pojoCommand xmlns=\"http://ws.apache.org/ns/synapse\" " +
+ "name=\"org.apache.synapse.mediators.ext.POJOCommandTestMediator\">" +
+ "<property name=\"testProp\" expression=\"fn:concat('XPATH ', 'FUNC')\" context-name=\"prop\" action=\"ReadContext\"/></pojoCommand>";
+ assertTrue(serialization(inputXml, pojoCommandMediatorFactory, pojoCommandMediatorSerializer));
+ assertTrue(serialization(inputXml, pojoCommandMediatorSerializer));
+ }
+
+ public void testPOJOCommandMediatorWithContextUpdatePropertySerialization() throws Exception {
+ String inputXml = "<pojoCommand xmlns=\"http://ws.apache.org/ns/synapse\" " +
+ "name=\"org.apache.synapse.mediators.ext.POJOCommandTestMediator\">" +
+ "<property name=\"testProp\" context-name=\"prop\" action=\"UpdateContext\"/></pojoCommand>";
+ assertTrue(serialization(inputXml, pojoCommandMediatorFactory, pojoCommandMediatorSerializer));
+ assertTrue(serialization(inputXml, pojoCommandMediatorSerializer));
+ }
+
+ public void testPOJOCommandMediatorWithContextR$UPropertySerialization() throws Exception {
+ String inputXml = "<pojoCommand xmlns=\"http://ws.apache.org/ns/synapse\" " +
+ "name=\"org.apache.synapse.mediators.ext.POJOCommandTestMediator\">" +
+ "<property name=\"testProp\" context-name=\"prop\" action=\"ReadAndUpdateContext\"/></pojoCommand>";
assertTrue(serialization(inputXml, pojoCommandMediatorFactory, pojoCommandMediatorSerializer));
assertTrue(serialization(inputXml, pojoCommandMediatorSerializer));
}
Modified: webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/mediators/ext/POJOCommandMediatorTest.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/mediators/ext/POJOCommandMediatorTest.java?rev=604103&r1=604102&r2=604103&view=diff
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/mediators/ext/POJOCommandMediatorTest.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/mediators/ext/POJOCommandMediatorTest.java Thu Dec 13 20:48:05 2007
@@ -46,7 +46,7 @@
Mediator pcm = MediatorFactoryFinder.getInstance().getMediator(createOMElement(
"<pojoCommand name='org.apache.synapse.mediators.ext.POJOCommandTestMediator' " +
"xmlns='http://ws.apache.org/ns/synapse'><property name=\"testProp\" " +
- "expression=\"fn:concat('XPATH ', 'FUNC')\"/></pojoCommand>"));
+ "expression=\"fn:concat('XPATH ', 'FUNC')\" action=\"ReadMessage\"/></pojoCommand>"));
POJOCommandTestHelper.reset();
pcm.mediate(new TestMessageContext());
assertEquals("XPATH FUNC", POJOCommandTestHelper.getInstance().getChangedProperty());
@@ -66,7 +66,7 @@
Mediator pcm = MediatorFactoryFinder.getInstance().getMediator(createOMElement(
"<pojoCommand name='org.apache.synapse.mediators.ext.POJOCommandTestImplementedMediator' " +
"xmlns='http://ws.apache.org/ns/synapse'><property name=\"testProp\" " +
- "expression=\"fn:concat('XPATH ', 'FUNC')\"/></pojoCommand>"));
+ "expression=\"fn:concat('XPATH ', 'FUNC')\" action=\"ReadMessage\"/></pojoCommand>"));
POJOCommandTestHelper.reset();
pcm.mediate(new TestMessageContext());
assertEquals("XPATH FUNC", POJOCommandTestHelper.getInstance().getChangedProperty());
@@ -88,7 +88,7 @@
Mediator pcm = MediatorFactoryFinder.getInstance().getMediator(createOMElement(
"<pojoCommand name='org.apache.synapse.mediators.ext.POJOCommandTestImplementedMediator' " +
"xmlns='http://ws.apache.org/ns/synapse'><property name=\"testProp\" " +
- "value=\"Test Property\"/><property name=\"testProp\" value=\"testPropInMC\" action=\"get\"/></pojoCommand>"));
+ "value=\"Test Property\" context-name=\"testPropInMC\"/></pojoCommand>"));
POJOCommandTestHelper.reset();
MessageContext ctx = new TestMessageContext();
pcm.mediate(ctx);
@@ -101,7 +101,7 @@
Mediator pcm = MediatorFactoryFinder.getInstance().getMediator(createOMElement(
"<pojoCommand name='org.apache.synapse.mediators.ext.POJOCommandTestImplementedMediator' " +
"xmlns='http://ws.apache.org/ns/synapse'><property name=\"testProp\" " +
- "value=\"TestProperty\"/><property name=\"testProp\" expression=\"//testNode\" action=\"get\"/></pojoCommand>"));
+ "value=\"TestProperty\" expression=\"//testNode\"/></pojoCommand>"));
POJOCommandTestHelper.reset();
MessageContext ctx = new TestMessageContext();
SOAPEnvelope envelope = OMAbstractFactory.getSOAP11Factory().getDefaultEnvelope();
@@ -110,6 +110,19 @@
pcm.mediate(ctx);
assertEquals("TestProperty", POJOCommandTestHelper.getInstance().getChangedProperty());
assertEquals("<original>TestProperty</original>", ctx.getEnvelope().getBody().getFirstOMChild().toString());
+ assertTrue(POJOCommandTestHelper.getInstance().isExecuted());
+ }
+
+ public void testPojoWithContextR$UPropertiesCommandImpl() throws Exception {
+ Mediator pcm = MediatorFactoryFinder.getInstance().getMediator(createOMElement(
+ "<pojoCommand name='org.apache.synapse.mediators.ext.POJOCommandTestImplementedMediator' " +
+ "xmlns='http://ws.apache.org/ns/synapse'><property name=\"ctxTest\" " +
+ "context-name=\"testCtxProp\" action=\"ReadAndUpdateContext\"/></pojoCommand>"));
+ POJOCommandTestHelper.reset();
+ MessageContext ctx = new TestMessageContext();
+ ctx.setProperty("testCtxProp", "test");
+ pcm.mediate(ctx);
+ assertEquals("testcommand", ctx.getProperty("testCtxProp").toString());
assertTrue(POJOCommandTestHelper.getInstance().isExecuted());
}
}
Modified: webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/mediators/ext/POJOCommandTestImplementedMediator.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/mediators/ext/POJOCommandTestImplementedMediator.java?rev=604103&r1=604102&r2=604103&view=diff
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/mediators/ext/POJOCommandTestImplementedMediator.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/test/java/org/apache/synapse/mediators/ext/POJOCommandTestImplementedMediator.java Thu Dec 13 20:48:05 2007
@@ -28,9 +28,11 @@
public class POJOCommandTestImplementedMediator implements Command {
public static String testProp = null;
+ private String ctxTest = "";
public void execute() {
POJOCommandTestHelper.getInstance().setExecuted(true);
+ ctxTest += "command";
}
public void setTestProp(String s) {
@@ -40,5 +42,13 @@
public String getTestProp() {
return testProp;
+ }
+
+ public String getCtxTest() {
+ return ctxTest;
+ }
+
+ public void setCtxTest(String ctxTest) {
+ this.ctxTest = ctxTest;
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: synapse-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: synapse-dev-help@ws.apache.org