Author: asankha
Date: Sun May 6 10:31:04 2007
New Revision: 535636
URL: http://svn.apache.org/viewvc?view=rev&rev=535636
Log:
add two more samples # 52 - POX to SOAP and #114 JMS to http and replying with
a 202 Accepted
modified client to send REST requests with a switch -Drest=true
Added:
webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_114.xml
webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_52.xml
Modified:
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2Sender.java
webservices/synapse/trunk/java/modules/nhttp/src/org/apache/axis2/transport/nhttp/HttpCoreNIOSender.java
webservices/synapse/trunk/java/modules/samples/src/main/java/samples/userguide/StockQuoteClient.java
webservices/synapse/trunk/java/modules/samples/src/main/scripts/build.xml
webservices/synapse/trunk/java/src/site/resources/Synapse_Samples.html
Modified:
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2Sender.java
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2Sender.java?view=diff&rev=535636&r1=535635&r2=535636
==============================================================================
---
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2Sender.java
(original)
+++
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2Sender.java
Sun May 6 10:31:04 2007
@@ -20,6 +20,7 @@
package org.apache.synapse.core.axis2;
import org.apache.axis2.AxisFault;
+import org.apache.axis2.util.Utils;
import org.apache.axis2.transport.nhttp.NhttpConstants;
import org.apache.axis2.context.MessageContext;
import org.apache.axis2.engine.AxisEngine;
@@ -64,7 +65,7 @@
// if this is a dummy 202 Accepted message meant only for the http/s
transports
// prevent it from going into any other transport sender
- if
(Boolean.TRUE.equals(messageContext.getProperty(NhttpConstants.SC_ACCEPTED)) &&
+ if (Utils.isExplicitlyTrue(messageContext, NhttpConstants.SC_ACCEPTED)
&&
messageContext.getTransportOut() != null &&
!messageContext.getTransportOut().getName().startsWith("http")) {
return;
Modified:
webservices/synapse/trunk/java/modules/nhttp/src/org/apache/axis2/transport/nhttp/HttpCoreNIOSender.java
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/nhttp/src/org/apache/axis2/transport/nhttp/HttpCoreNIOSender.java?view=diff&rev=535636&r1=535635&r2=535636
==============================================================================
---
webservices/synapse/trunk/java/modules/nhttp/src/org/apache/axis2/transport/nhttp/HttpCoreNIOSender.java
(original)
+++
webservices/synapse/trunk/java/modules/nhttp/src/org/apache/axis2/transport/nhttp/HttpCoreNIOSender.java
Sun May 6 10:31:04 2007
@@ -34,6 +34,7 @@
import org.apache.axis2.AxisFault;
import org.apache.axis2.Constants;
import org.apache.axis2.util.MessageContextBuilder;
+import org.apache.axis2.util.Utils;
import org.apache.axis2.addressing.AddressingConstants;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.context.ConfigurationContext;
@@ -311,7 +312,7 @@
// if this is a dummy message to handle http 202 case with
non-blocking IO
// set the status code to 202 and the message body to an empty byte
array (see below)
- if
(Boolean.TRUE.equals(msgContext.getProperty(NhttpConstants.SC_ACCEPTED))) {
+ if (Utils.isExplicitlyTrue(msgContext, NhttpConstants.SC_ACCEPTED)) {
response.setStatusCode(HttpStatus.SC_ACCEPTED);
}
@@ -331,7 +332,7 @@
OutputStream out = worker.getOutputStream();
try {
- if
(!Boolean.TRUE.equals(msgContext.getProperty(NhttpConstants.SC_ACCEPTED))) {
+ if (!Utils.isExplicitlyTrue(msgContext,
NhttpConstants.SC_ACCEPTED)) {
messageFormatter.writeTo(msgContext, format, out, true);
} else {
// see comment above on the reasoning
Modified:
webservices/synapse/trunk/java/modules/samples/src/main/java/samples/userguide/StockQuoteClient.java
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/samples/src/main/java/samples/userguide/StockQuoteClient.java?view=diff&rev=535636&r1=535635&r2=535636
==============================================================================
---
webservices/synapse/trunk/java/modules/samples/src/main/java/samples/userguide/StockQuoteClient.java
(original)
+++
webservices/synapse/trunk/java/modules/samples/src/main/java/samples/userguide/StockQuoteClient.java
Sun May 6 10:31:04 2007
@@ -37,11 +37,7 @@
import java.net.URL;
/**
- * ant stockquote
- * [-Dsymbol=<sym>] [-Drepository=<repo>] [-Dpolicy=<policy>]
- * [-Dmode=quote | customquote | fullquote | placeorder | marketactivity]
- * [-Daddressingurl=<url>] [-Dtransporturl=<url> | -Dproxyurl=<url>]
- *
+ * See build.xml for options
*/
public class StockQuoteClient {
@@ -63,6 +59,7 @@
String prxUrl = getProperty("prxurl", null);
String repo = getProperty("repository", "client_repo");
String svcPolicy = getProperty("policy", null);
+ String rest = getProperty("rest", null);
double price = 0; int quantity = 0;
@@ -127,7 +124,10 @@
RampartMessageData.KEY_RAMPART_POLICY,
loadPolicy(svcPolicy));
}
-
+ if (Boolean.parseBoolean(rest)) {
+ options.setProperty(Constants.Configuration.ENABLE_REST,
Constants.VALUE_TRUE);
+ }
+
serviceClient.setOptions(options);
if ("placeorder".equals(mode)) {
Modified:
webservices/synapse/trunk/java/modules/samples/src/main/scripts/build.xml
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/samples/src/main/scripts/build.xml?view=diff&rev=535636&r1=535635&r2=535636
==============================================================================
--- webservices/synapse/trunk/java/modules/samples/src/main/scripts/build.xml
(original)
+++ webservices/synapse/trunk/java/modules/samples/src/main/scripts/build.xml
Sun May 6 10:31:04 2007
@@ -34,6 +34,7 @@
[-Daddurl=http://localhost:9000/soap/SimpleStockQuoteService]
[-Dtrpurl=http://localhost:8080]
[-Dprxurl=http://localhost:8080]
+ [-Drest=true]
[-Dpolicy=../../repository/conf/sample/resources/policy/policy_1.xml]
Mode :
@@ -71,6 +72,7 @@
<property name="prxurl" value=""/>
<property name="repository" value=""/>
<property name="policy" value=""/>
+ <property name="rest" value=""/>
<property name="jms_dest" value=""/>
<property name="jms_type" value=""/>
<property name="jms_payload" value=""/>
@@ -100,6 +102,7 @@
<sysproperty key="prxurl" value="${prxurl}"/>
<sysproperty key="repository" value="${repository}"/>
<sysproperty key="policy" value="${policy}"/>
+ <sysproperty key="rest" value="${rest}"/>
</java>
</target>
Added:
webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_114.xml
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_114.xml?view=auto&rev=535636
==============================================================================
---
webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_114.xml
(added)
+++
webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_114.xml
Sun May 6 10:31:04 2007
@@ -0,0 +1,50 @@
+<!--
+ ~ Licensed to the Apache Software Foundation (ASF) under one
+ ~ or more contributor license agreements. See the NOTICE file
+ ~ distributed with this work for additional information
+ ~ regarding copyright ownership. The ASF licenses this file
+ ~ to you under the Apache License, Version 2.0 (the
+ ~ "License"); you may not use this file except in compliance
+ ~ with the License. You may obtain a copy of the License at
+ ~
+ ~ http://www.apache.org/licenses/LICENSE-2.0
+ ~
+ ~ Unless required by applicable law or agreed to in writing,
+ ~ software distributed under the License is distributed on an
+ ~ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ ~ KIND, either express or implied. See the License for the
+ ~ specific language governing permissions and limitations
+ ~ under the License.
+ -->
+<!-- one-way message bridging between JMS to HTTP and sending a 202 Accepted
-->
+<definitions xmlns="http://ws.apache.org/ns/synapse";>
+
+ <proxy name="JMStoHTTPStockQuoteProxy" transports="jms">
+ <target>
+ <endpoint>
+ <address
uri="http://localhost:9001/soap/SimpleStockQuoteService"/>
+ </endpoint>
+ <outSequence>
+ <send/>
+ </outSequence>
+ </target>
+ <publishWSDL
uri="file:repository/conf/sample/resources/proxy/sample_proxy_1.wsdl"/>
+ </proxy>
+
+ <proxy name="OneWayProxy" transports="http">
+ <target>
+ <inSequence>
+ <log level="full"/>
+ <property name="RESPONSE" value="true"/>
+ <header name="To"
value="http://www.w3.org/2005/08/addressing/anonymous"/>
+ <property name="SC_ACCEPTED" value="true" scope="axis2"/>
+ <send/>
+ </inSequence>
+ <outSequence>
+ <send/>
+ </outSequence>
+ </target>
+ <publishWSDL
uri="file:repository/conf/sample/resources/proxy/sample_proxy_1.wsdl"/>
+ </proxy>
+
+</definitions>
\ No newline at end of file
Added:
webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_52.xml
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_52.xml?view=auto&rev=535636
==============================================================================
--- webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_52.xml
(added)
+++ webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_52.xml
Sun May 6 10:31:04 2007
@@ -0,0 +1,31 @@
+<!--
+ ~ Licensed to the Apache Software Foundation (ASF) under one
+ ~ or more contributor license agreements. See the NOTICE file
+ ~ distributed with this work for additional information
+ ~ regarding copyright ownership. The ASF licenses this file
+ ~ to you under the Apache License, Version 2.0 (the
+ ~ "License"); you may not use this file except in compliance
+ ~ with the License. You may obtain a copy of the License at
+ ~
+ ~ http://www.apache.org/licenses/LICENSE-2.0
+ ~
+ ~ Unless required by applicable law or agreed to in writing,
+ ~ software distributed under the License is distributed on an
+ ~ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ ~ KIND, either express or implied. See the License for the
+ ~ specific language governing permissions and limitations
+ ~ under the License.
+ -->
+<!-- POX to SOAP conversion -->
+<definitions xmlns="http://ws.apache.org/ns/synapse";>
+ <!-- filtering of messages with XPath and regex matches -->
+ <filter source="get-property('To')" regex=".*/StockQuote.*">
+ <send>
+ <endpoint>
+ <address
uri="http://localhost:9000/soap/SimpleStockQuoteService"; format="soap"/>
+ </endpoint>
+ </send>
+ <drop/>
+ </filter>
+ <send/>
+</definitions>
Modified: webservices/synapse/trunk/java/src/site/resources/Synapse_Samples.html
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/src/site/resources/Synapse_Samples.html?view=diff&rev=535636&r1=535635&r2=535636
==============================================================================
--- webservices/synapse/trunk/java/src/site/resources/Synapse_Samples.html
(original)
+++ webservices/synapse/trunk/java/src/site/resources/Synapse_Samples.html Sun
May 6 10:31:04 2007
@@ -156,6 +156,7 @@
messages</a></li>
<li><a href="#Sample51">Sample 51: MTOM and SwA optimizations and
request/response correlation</a></li>
+ <li><a href="#Sample52">Sample 52: POX to SOAP conversion</a></li>
</ul>
</li>
<li><a href="#ProxyServices">Synapse Proxy service samples</a>
@@ -180,6 +181,7 @@
fireAndForget()</a></li>
<li><a href="#Sample113">Sample 113: Pure text/binary and POX message
support with JMS</a></li>
+ <li><a href="#Sample114">Sample 114: One way bridging from JMS to http
and replying with a 202 Accepted response</a></li>
</ul>
</li>
<li><a href="#ScriptMediators">Script Mediators</a>
@@ -418,8 +420,8 @@
context properties as well as transport headers. The local entry definition
for "version" defines a simple text/string registry entry for that is visible
to all messages that passes through Synapse.</p>
-<pre>[HttpServerWorker-1] INFO LogMediator - Text = Sending quote request,
version = 0.1, direction = incoming
-[HttpServerWorker-1] DEBUG SendMediator - Send mediator :: mediate()
+<pre>[HttpServerWorker-1] INFO LogMediator - Text = Sending quote request,
version = 0.1, direction = incoming
+[HttpServerWorker-1] DEBUG SendMediator - Send mediator :: mediate()
[HttpServerWorker-1] DEBUG AddressEndpoint - Sending To:
http://localhost:9000/soap/SimpleStockQuoteService </pre>
<h2><a name="Sample4">Sample 4:</a></h2>
@@ -499,11 +501,11 @@
'fault'. Thus the 'fault' sequence can be seen executing, and writing the
generic error message into the logs. </p>
<pre>ant stockquote
-Daddurl=http://localhost:9000/soap/SimpleStockQuoteService
-Dtrpurl=http://localhost:8080/ -Dsymbol=MSFT</pre>
-<pre>[HttpServerWorker-1] DEBUG SendMediator - Send mediator :: mediate()
-[HttpServerWorker-1] ERROR IndirectEndpoint - Reference to non-existent
endpoint for key : bogus
-[HttpServerWorker-1] DEBUG MediatorFaultHandler - MediatorFaultHandler ::
handleFault
-[HttpServerWorker-1] DEBUG SequenceMediator - Sequence mediator <fault>
:: mediate()
-[HttpServerWorker-1] DEBUG LogMediator - Log mediator :: mediate()
+<pre>[HttpServerWorker-1] DEBUG SendMediator - Send mediator :: mediate()
+[HttpServerWorker-1] ERROR IndirectEndpoint - Reference to non-existent
endpoint for key : bogus
+[HttpServerWorker-1] DEBUG MediatorFaultHandler - MediatorFaultHandler ::
handleFault
+[HttpServerWorker-1] DEBUG SequenceMediator - Sequence mediator <fault>
:: mediate()
+[HttpServerWorker-1] DEBUG LogMediator - Log mediator :: mediate()
[HttpServerWorker-1] INFO LogMediator - text = An unexpected error occured,
message = Reference to non-existent endpoint for key : bogus</pre>
<p>When the 'SUN' quote is requested, a custom sequence 'sunSequence' is
@@ -511,15 +513,15 @@
the send fails, now you could see the proper error handler invocation and the
custom error message as follows:</p>
<pre>ant stockquote
-Daddurl=http://localhost:9000/soap/SimpleStockQuoteService
-Dtrpurl=http://localhost:8080/ -Dsymbol=SUN</pre>
-<pre>[HttpServerWorker-1] DEBUG SequenceMediator - Sequence mediator
<sunSequence> :: mediate()
-[HttpServerWorker-1] DEBUG SequenceMediator - Setting the onError handler for
the sequence
-[HttpServerWorker-1] DEBUG AbstractListMediator - Implicit Sequence
<SequenceMediator> :: mediate()
-[HttpServerWorker-1] DEBUG SendMediator - Send mediator :: mediate()
-[HttpServerWorker-1] ERROR IndirectEndpoint - Reference to non-existent
endpoint for key : sunPort
-[HttpServerWorker-1] DEBUG MediatorFaultHandler - MediatorFaultHandler ::
handleFault
-[HttpServerWorker-1] DEBUG SequenceMediator - Sequence mediator
<sunErrorHandler> :: mediate()
-[HttpServerWorker-1] DEBUG AbstractListMediator - Implicit Sequence
<SequenceMediator> :: mediate()
-[HttpServerWorker-1] DEBUG LogMediator - Log mediator :: mediate()
+<pre>[HttpServerWorker-1] DEBUG SequenceMediator - Sequence mediator
<sunSequence> :: mediate()
+[HttpServerWorker-1] DEBUG SequenceMediator - Setting the onError handler for
the sequence
+[HttpServerWorker-1] DEBUG AbstractListMediator - Implicit Sequence
<SequenceMediator> :: mediate()
+[HttpServerWorker-1] DEBUG SendMediator - Send mediator :: mediate()
+[HttpServerWorker-1] ERROR IndirectEndpoint - Reference to non-existent
endpoint for key : sunPort
+[HttpServerWorker-1] DEBUG MediatorFaultHandler - MediatorFaultHandler ::
handleFault
+[HttpServerWorker-1] DEBUG SequenceMediator - Sequence mediator
<sunErrorHandler> :: mediate()
+[HttpServerWorker-1] DEBUG AbstractListMediator - Implicit Sequence
<SequenceMediator> :: mediate()
+[HttpServerWorker-1] DEBUG LogMediator - Log mediator :: mediate()
[HttpServerWorker-1] INFO LogMediator - text = An unexpected error occured
for stock SUN, message = Reference to non-existent endpoint for key :
sunPort</pre>
<h2><a name="Sample5">Sample 5:</a></h2>
@@ -742,9 +744,9 @@
<p>Execute the custom quote client as 'ant stockquote -Dmode=customquote ..'
and analyze the the Synapse debug log output as shown below</p>
<pre>ant stockquote
-Daddurl=http://localhost:9000/soap/SimpleStockQuoteService
-Dtrpurl=http://localhost:8080/ -Dmode=customquote</pre>
-<pre>[HttpServerWorker-1] DEBUG XSLTMediator - Performing XSLT transformation
against property with key : xslt-key-req
-[HttpServerWorker-1] DEBUG XSLTMediator - Transformation source :
- <m0:CheckPriceRequest
xmlns:m0="http://www.apache-synapse.org/test"><m0:Code>IBM</m0:Code></m0:CheckPriceRequest>
+<pre>[HttpServerWorker-1] DEBUG XSLTMediator - Performing XSLT transformation
against property with key : xslt-key-req
+[HttpServerWorker-1] DEBUG XSLTMediator - Transformation source :
+ <m0:CheckPriceRequest
xmlns:m0="http://www.apache-synapse.org/test"><m0:Code>IBM</m0:Code></m0:CheckPriceRequest>
[HttpServerWorker-1] DEBUG XSLTMediator - Transformation result :
<m:getQuote xmlns:m="http://services.samples/xsd"></pre>
<p>The incoming message is now transformed into a standard stock quote
@@ -771,9 +773,9 @@
resource is not necessary (i.e. unless the resource itself actually changed)
the updated meta information is used and the cache lease extended as
appropriate.</p>
-<pre>[HttpClientWorker-1] DEBUG AbstractRegistry - Cached object has expired
for key : transform/transform_back.xslt
-[HttpClientWorker-1] DEBUG SimpleURLRegistry - Perform RegistryEntry lookup
for key : transform/transform_back.xslt
-[HttpClientWorker-1] DEBUG AbstractRegistry - Expired version number is same
as current version in registry
+<pre>[HttpClientWorker-1] DEBUG AbstractRegistry - Cached object has expired
for key : transform/transform_back.xslt
+[HttpClientWorker-1] DEBUG SimpleURLRegistry - Perform RegistryEntry lookup
for key : transform/transform_back.xslt
+[HttpClientWorker-1] DEBUG AbstractRegistry - Expired version number is same
as current version in registry
[HttpClientWorker-1] DEBUG AbstractRegistry - Renew cache lease for another
15s </pre>
<p>Now edit the
@@ -781,8 +783,8 @@
blank line at the end. Now when you run the client again, and if the cache is
expired, the resource would be re-fetched from its URL by the registry and
this can be seen by the following debug log messages</p>
-<pre>[HttpClientWorker-1] DEBUG AbstractRegistry - Cached object has expired
for key : transform/transform_back.xslt
-[HttpClientWorker-1] DEBUG SimpleURLRegistry - Perform RegistryEntry lookup
for key : transform/transform_back.xslt
+<pre>[HttpClientWorker-1] DEBUG AbstractRegistry - Cached object has expired
for key : transform/transform_back.xslt
+[HttpClientWorker-1] DEBUG SimpleURLRegistry - Perform RegistryEntry lookup
for key : transform/transform_back.xslt
[HttpClientWorker-1] INFO SimpleURLRegistry - ==> Repository fetch of
resource with key : transform/transform_back.xslt </pre>
<p>Thus the SimpleURLRegistry allows resource to be cached, and updates
@@ -821,9 +823,9 @@
<p>Once Synapse is started, execute the stock quote client as 'ant
stockquote..'. You will notice that that Synapse fetches the definition of
the sequence from the registry and executes its rules as follows:</p>
-<pre>[HttpServerWorker-1] INFO SimpleURLRegistry - ==> Repository fetch of
resource with key : sequence/dynamic_seq_1.xml
+<pre>[HttpServerWorker-1] INFO SimpleURLRegistry - ==> Repository fetch of
resource with key : sequence/dynamic_seq_1.xml
...
-[HttpServerWorker-1] DEBUG SequenceMediator - Sequence mediator
<dynamic_sequence> :: mediate()
+[HttpServerWorker-1] DEBUG SequenceMediator - Sequence mediator
<dynamic_sequence> :: mediate()
...
[HttpServerWorker-1] INFO LogMediator - message = *** Test Message 1 ***</pre>
@@ -837,9 +839,9 @@
15 seconds have elapsed since the original caching of the sequence, you will
notice that the new sequence is loaded and executed by Synapse from the
following log messages:</p>
-<pre>[HttpServerWorker-1] INFO SimpleURLRegistry - ==> Repository fetch of
resource with key : sequence/dynamic_seq_1.xml
+<pre>[HttpServerWorker-1] INFO SimpleURLRegistry - ==> Repository fetch of
resource with key : sequence/dynamic_seq_1.xml
...
-[HttpServerWorker-1] DEBUG SequenceMediator - Sequence mediator
<dynamic_sequence> :: mediate()
+[HttpServerWorker-1] DEBUG SequenceMediator - Sequence mediator
<dynamic_sequence> :: mediate()
...
[HttpServerWorker-1] INFO LogMediator - message = *** Test Message 2 ***</pre>
@@ -918,7 +920,7 @@
<p>The actual synapse.xml loaded is:</p>
<pre><!-- a registry based Synapse configuration -->
-<definitions xmlns="http://ws.apache.org/ns/synapse">
+<definitions xmlns="http://ws.apache.org/ns/synapse">
<log level="custom">
<property name="message" value="This is a dynamic Synapse
configuration $$$"/>
</log>
@@ -1017,7 +1019,7 @@
<soapenv:Body
xmlns:wsu="http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-utility-1.0.xsd";
wsu:Id="Id-3789605">
<xenc:EncryptedData Id="EncDataId-3789605"
Type="http://www.w3.org/2001/04/xmlenc#Content">
<xenc:EncryptionMethod
Algorithm="http://www.w3.org/2001/04/xmlenc#aes256-cbc"; />
- <xenc:CipherData>
+ <xenc:CipherData>
<xenc:CipherValue>Layg0xQcnH....6UKm5nKU6Qqr</xenc:CipherValue>
</xenc:CipherData>
</xenc:EncryptedData>
@@ -1094,7 +1096,7 @@
<pre>POST http://localhost:9000/soap/MTOMSwASampleService HTTP/1.1
Host: 127.0.0.1
SOAPAction: urn:uploadFileUsingMTOM
-Content-Type: multipart/related;
boundary=MIMEBoundaryurn_uuid_B94996494E1DD5F9B51177413845353;
type="application/xop+xml";
+Content-Type: multipart/related;
boundary=MIMEBoundaryurn_uuid_B94996494E1DD5F9B51177413845353;
type="application/xop+xml";
start="<0.urn:uuid:[EMAIL PROTECTED]>"; start-info="text/xml";
charset=UTF-8
Transfer-Encoding: chunked
Connection: Keep-Alive
@@ -1103,7 +1105,7 @@
--MIMEBoundaryurn_uuid_B94996494E1DD5F9B51177413845353241
Content-Type: application/xop+xml; charset=UTF-8; type="text/xml"
Content-Transfer-Encoding: binary
-Content-ID:
+Content-ID:
<0.urn:uuid:[EMAIL PROTECTED]>221b1
<?xml version='1.0' encoding='UTF-8'?>
<soapenv:Envelope
xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/">
@@ -1120,12 +1122,12 @@
--MIMEBoundaryurn_uuid_B94996494E1DD5F9B51177413845353217
Content-Type: image/gif
Content-Transfer-Encoding: binary
-Content-ID:
+Content-ID:
<1.urn:uuid:[EMAIL PROTECTED]>22800GIF89a... << binary
content >></pre>
<pre>POST http://localhost:9000/soap/MTOMSwASampleService HTTP/1.1
Host: 127.0.0.1
SOAPAction: urn:uploadFileUsingSwA
-Content-Type: multipart/related;
boundary=MIMEBoundaryurn_uuid_B94996494E1DD5F9B51177414170491; type="text/xml";
+Content-Type: multipart/related;
boundary=MIMEBoundaryurn_uuid_B94996494E1DD5F9B51177414170491; type="text/xml";
start="<0.urn:uuid:[EMAIL PROTECTED]>"; charset=UTF-8
Transfer-Encoding: chunked
Connection: Keep-Alive
@@ -1134,7 +1136,7 @@
--MIMEBoundaryurn_uuid_B94996494E1DD5F9B51177414170491225
Content-Type: text/xml; charset=UTF-8
Content-Transfer-Encoding: 8bit
-Content-ID:
+Content-ID:
<0.urn:uuid:[EMAIL PROTECTED]>22159
<?xml version='1.0' encoding='UTF-8'?>
<soapenv:Envelope
xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/">
@@ -1149,9 +1151,52 @@
17
Content-Type: image/gif
Content-Transfer-Encoding: binary
-Content-ID:
+Content-ID:
<urn:uuid:15FD2DA2584A32BF7C1177414169826>22800GIF89a...
<< binary content >></pre>
+<h2><a name="Sample52">Sample 52:</a></h2>
+<pre><!-- POX to SOAP conversion -->
+<definitions xmlns="http://ws.apache.org/ns/synapse">
+ <!-- filtering of messages with XPath and regex matches -->
+ <filter source="get-property('To')" regex=".*/StockQuote.*">
+ <send>
+ <endpoint>
+ <address
uri="http://localhost:9000/soap/SimpleStockQuoteService"; format="soap"/>
+ </endpoint>
+ </send>
+ <drop/>
+ </filter>
+ <send/>
+</definitions> </pre>
+
+<p><strong>Objective: POX to SOAP conversion</strong></p>
+
+<p><strong>Pre-Requisites:</strong><br>
+Start the Synapse configuration numbered 52: i.e. synapse -sample 52\</p>
+
+<p>Start the Axis2 server and deploy the SimpleStockQuoteService if not
+already done</p>
+
+<p>Execute the 'ant stockquote' specifying that the request should be a REST
+request as follows:</p>
+<pre>ant stockquote -Dtrpurl=http://localhost:8081/soap/StockQuote
-Drest=true</pre>
+
+<p>This example shows a http REST request (as shown below) being transformed
+into a SOAP request and forwarded to the stock quote service. </p>
+<pre>POST /soap/StockQuote HTTP/1.1
+Content-Type: application/xml; charset=UTF-8;action="urn:getQuote";
+SOAPAction: urn:getQuote
+User-Agent: Axis2
+Host: 127.0.0.1
+Transfer-Encoding: chunked
+
+75
+<m0:getQuote xmlns:m0="http://services.samples/xsd">
+ <m0:request>
+ <m0:symbol>IBM</m0:symbol>
+ </m0:request>
+</m0:getQuote>0</pre>
+
<h1><a name="ProxyServices" id="ProxyServices">Proxy services</a></h1>
<h2><a name="Sample100">Sample 100:</a></h2>
@@ -1398,7 +1443,7 @@
<h1><a name="Transport">Transports</a></h1>
<h2><a name="Sample110">Sample 110:</a></h2>
-<pre><definitions xmlns="http://ws.apache.org/ns/synapse">
+<pre><definitions xmlns="http://ws.apache.org/ns/synapse">
<proxy name="StockQuoteProxy" transports="jms">
<target>
@@ -1641,7 +1686,7 @@
text message and transformed it into a SOAP payload as follows. Notice that
the wrapper element "{http://services.samples/xsd}text"; has been used to hold
the text message content.</p>
-<pre>[JMSWorker-1] DEBUG ProxyServiceMessageReceiver - Body :
+<pre>[JMSWorker-1] DEBUG ProxyServiceMessageReceiver - Body :
<?xml version='1.0' encoding='utf-8'?><soapenv:Envelope
xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/">
<soapenv:Body><axis2ns1:text
xmlns:axis2ns1="http://services.samples/xsd">12.33 1000
ACP</axis2ns1:text></soapenv:Body>
</soapenv:Envelope></pre>
@@ -1649,10 +1694,10 @@
<p>Now, you could see how the script mediator created a stock quote request
by tokenizing the text as follows, and sent the message to the placeOrder
operation of the SimpleStockQuoteService.</p>
-<pre>[JMSWorker-1] DEBUG AddressEndpoint - Sending message to endpoint :: name
= AnonymousEndpoints resolved address =
http://localhost:9000/soap/SimpleStockQuoteService
-[JMSWorker-1] DEBUG AddressEndpoint - SOAPAction: urn:placeOrder
-[JMSWorker-1] DEBUG AddressEndpoint - WSA-Action: urn:placeOrder
-[JMSWorker-1] DEBUG AddressEndpoint - Body :
+<pre>[JMSWorker-1] DEBUG AddressEndpoint - Sending message to endpoint :: name
= AnonymousEndpoints resolved address =
http://localhost:9000/soap/SimpleStockQuoteService
+[JMSWorker-1] DEBUG AddressEndpoint - SOAPAction: urn:placeOrder
+[JMSWorker-1] DEBUG AddressEndpoint - WSA-Action: urn:placeOrder
+[JMSWorker-1] DEBUG AddressEndpoint - Body :
<?xml version='1.0' encoding='utf-8'?><soapenv:Envelope
xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"><soapenv:Body>
<m:placeOrder
xmlns:m="http://services.samples/xsd"><m:order><m:price>12.33</m:price><m:quantity>1000</m:quantity><m:symbol>ACP</m:symbol></m:order>
</m:placeOrder></soapenv:Body></soapenv:Envelope></pre>
@@ -1679,9 +1724,9 @@
<p>Examining the Synapse debug logs reveals that the binary content was
received over JMS and wrapped with the specified element into a SOAP infoset
as follows:</p>
-<pre>[JMSWorker-1] DEBUG ProxyServiceMessageReceiver - Proxy Service
JMSFileUploadProxy received a new message...
+<pre>[JMSWorker-1] DEBUG ProxyServiceMessageReceiver - Proxy Service
JMSFileUploadProxy received a new message...
...
-[JMSWorker-1] DEBUG ProxyServiceMessageReceiver - Body :
+[JMSWorker-1] DEBUG ProxyServiceMessageReceiver - Body :
<?xml version='1.0' encoding='utf-8'?><soapenv:Envelope
xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/">
<soapenv:Body><axis2ns1:element
xmlns:axis2ns1="http://services.samples/xsd">R0lGODlhgw...AAOw==</axis2ns1:element></soapenv:Body>
</soapenv:Envelope></pre>
@@ -1708,36 +1753,106 @@
'urn:placeOrder'.</p>
<p></p>
-<pre>[JMSWorker-1] DEBUG ProxyServiceMessageReceiver - Proxy Service
JMSPoxProxy received a new message...
+<pre>[JMSWorker-1] DEBUG ProxyServiceMessageReceiver - Proxy Service
JMSPoxProxy received a new message...
...
-[JMSWorker-1] DEBUG ProxyServiceMessageReceiver - Body :
+[JMSWorker-1] DEBUG ProxyServiceMessageReceiver - Body :
<?xml version='1.0' encoding='utf-8'?><soapenv:Envelope
xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"><soapenv:Body><m:placeOrder
xmlns:m="http://services.samples/xsd">
<m:order>
<m:price>172.39703010684752</m:price>
<m:quantity>19211</m:quantity>
<m:symbol>MSFT</m:symbol>
</m:order>
-</m:placeOrder></soapenv:Body></soapenv:Envelope>
-[JMSWorker-1] DEBUG ProxyServiceMessageReceiver - Using the sequence named
pox_proxy for message mediation
+</m:placeOrder></soapenv:Body></soapenv:Envelope>
+[JMSWorker-1] DEBUG ProxyServiceMessageReceiver - Using the sequence named
pox_proxy for message mediation
...
-[JMSWorker-1] DEBUG HeaderMediator - Setting header : Action to :
urn:placeOrder
+[JMSWorker-1] DEBUG HeaderMediator - Setting header : Action to :
urn:placeOrder
...
-[JMSWorker-1] DEBUG AddressEndpoint - Sending message to endpoint :: name =
AnonymousEndpoints resolved address =
http://localhost:9000/soap/SimpleStockQuoteService
-[JMSWorker-1] DEBUG AddressEndpoint - SOAPAction: urn:placeOrder
-[JMSWorker-1] DEBUG AddressEndpoint - Body :
+[JMSWorker-1] DEBUG AddressEndpoint - Sending message to endpoint :: name =
AnonymousEndpoints resolved address =
http://localhost:9000/soap/SimpleStockQuoteService
+[JMSWorker-1] DEBUG AddressEndpoint - SOAPAction: urn:placeOrder
+[JMSWorker-1] DEBUG AddressEndpoint - Body :
<?xml version='1.0' encoding='utf-8'?><soapenv:Envelope
xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"><soapenv:Body><m:placeOrder
xmlns:m="http://services.samples/xsd">
<m:order>
<m:price>172.39703010684752</m:price>
<m:quantity>19211</m:quantity>
<m:symbol>MSFT</m:symbol>
</m:order>
-</m:placeOrder></soapenv:Body></soapenv:Envelope>
+</m:placeOrder></soapenv:Body></soapenv:Envelope>
[JMSWorker-1] DEBUG Axis2FlexibleMEPClient - sending [add = false] [sec =
false] [rm = false] [ mtom = false] [ swa = false] [ force soap=true;
pox=false] [ to null] </pre>
<p>The sample Axis2 server displays a successful message on the receipt of
the message as:</p>
<pre>Wed Apr 25 20:24:50 LKT 2007 samples.services.SimpleStockQuoteService ::
Accepted order for : 19211 stocks of MSFT at $ 172.39703010684752</pre>
+<h2><a name="Sample114">Sample 114:</a></h2>
+<pre><!-- one-way message bridging between JMS to HTTP and sending a 202
Accepted -->
+<definitions xmlns="http://ws.apache.org/ns/synapse">
+
+ <proxy name="JMStoHTTPStockQuoteProxy" transports="jms">
+ <target>
+ <endpoint>
+ <address
uri="http://localhost:9001/soap/SimpleStockQuoteService"/>
+ </endpoint>
+ <outSequence>
+ <send/>
+ </outSequence>
+ </target>
+ <publishWSDL
uri="file:repository/conf/sample/resources/proxy/sample_proxy_1.wsdl"/>
+ </proxy>
+
+ <proxy name="OneWayProxy" transports="http">
+ <target>
+ <inSequence>
+ <log level="full"/>
+ <property name="RESPONSE" value="true"/>
+ <header name="To"
value="http://www.w3.org/2005/08/addressing/anonymous"/>
+ <property name="SC_ACCEPTED" value="true" scope="axis2"/>
+ <send/>
+ </inSequence>
+ <outSequence>
+ <send/>
+ </outSequence>
+ </target>
+ <publishWSDL
uri="file:repository/conf/sample/resources/proxy/sample_proxy_1.wsdl"/>
+ </proxy>
+
+</definitions></pre>
+
+<p><strong>Objective: Demonstrate one way message bridging from JMS to http
+and replying with a http 202 Accepted response</strong></p>
+
+<p><strong>Pre-Requisites:</strong><br>
+Start the Axis2 server and deploy the SimpleStockQuoteService if not already
+done</p>
+
+<p>Start the Synapse configuration numbered 114: i.e. synapse -sample 114</p>
+
+<p></p>
+
+<p>This example invokes the one-way 'placeOrder' operation on the
+SimpleStockQuoteService using the Axis2 ServiceClient.fireAndForget() API at
+the client. To test this, use 'ant -Dmode=placeorder...' and you will notice
+the one way JMS message flowing through Synapse into the sample Axis2 server
+instance over http, and Axis2 acknowledging it with a http 202 Accepted
+response.</p>
+<pre>ant stockquote -Dmode=placeorder
-Dtrpurl="jms:/JMStoHTTPStockQuoteProxy?transport.jms.ConnectionFactoryJNDIName=QueueConnectionFactory&java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory&java.naming.provider.url=tcp://localhost:61616"</pre>
+<pre>SimpleStockQuoteService :: Accepted order for : 7482 stocks of IBM at $
169.27205579038733</pre>
+
+<p>The second example shows how Synapse could be made to respond with a http
+202 Accepted response to a request received. The proxy service simply logs
+the message received and acknowledges it. On the Synapse console you could
+see the logged message, and if TCPMon was used at the client, you would see
+the 202 Accepted response sent back to the client from Synapse</p>
+<pre>ant stockquote -Dmode=placeorder
-Dtrpurl=http://asankha:8080/soap/OneWayProxy</pre>
+<pre>HTTP/1.1 202 Accepted
+Content-Type: text/xml; charset=UTF-8
+Host: 127.0.0.1
+SOAPAction: "urn:placeOrder"
+Date: Sun, 06 May 2007 17:20:19 GMT
+Server: Synapse-HttpComponents-NIO
+Transfer-Encoding: chunked
+
+0</pre>
+
<h1><a name="ScriptMediators">Script mediators</a></h1>
<p>Synapse supports Mediators implemented in a variety of scripting languages
@@ -1916,7 +2031,7 @@
property to mark it as a response. Execute the stock quote client, and you
will receive the response "99.9" as the last sale price as per the above
script.</p>
-<pre>ant stockquote
-Daddurl=http://localhost:9000/soap/SimpleStockQuoteService
-Dtrpurl=http://localhost:8080/
+<pre>ant stockquote
-Daddurl=http://localhost:9000/soap/SimpleStockQuoteService
-Dtrpurl=http://localhost:8080/
...
stockquote:
[java] Standard :: Stock price = $99.9</pre>
@@ -1947,14 +2062,14 @@
require 'rexml/document'
include REXML
-def transformRequest(mc)
+def transformRequest(mc)
newRequest= Document.new '<m:getQuote
xmlns:m="http://services.samples/xsd">'<<
'<m:request><m:symbol></m:symbol></m:request></m:getQuote>'
newRequest.root.elements[1].elements[1].text =
mc.getPayloadXML().root.elements[1].get_text
mc.setPayloadXML(newRequest)
end
-def transformResponse(mc)
+def transformResponse(mc)
newResponse = Document.new '<m:CheckPriceResponse
xmlns:m="http://www.apache-synapse.org/test"><m:Code>' <<
'</m:Code><m:Price></m:Price></m:CheckPriceResponse>'
newResponse.root.elements[1].text =
mc.getPayloadXML().root.elements[1].elements[1].get_text
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
