You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@synapse.apache.org by as...@apache.org on 2007/03/21 13:11:41 UTC
svn commit: r520851 - in /webservices/synapse/trunk/java:
modules/core/src/main/java/org/apache/synapse/core/axis2/
modules/nhttp/src/org/apache/axis2/transport/nhttp/ repository/conf/sample/
Author: asankha
Date: Wed Mar 21 05:11:40 2007
New Revision: 520851
URL: http://svn.apache.org/viewvc?view=rev&rev=520851
Log:
fix sample #50 for rampart outgoing messages with latest axis2 and rampart versions
Modified:
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/AnonymousServiceFactory.java
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2FlexibleMEPClient.java
webservices/synapse/trunk/java/modules/nhttp/src/org/apache/axis2/transport/nhttp/ClientWorker.java
webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_50.xml
Modified: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/AnonymousServiceFactory.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/AnonymousServiceFactory.java?view=diff&rev=520851&r1=520850&r2=520851
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/AnonymousServiceFactory.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/AnonymousServiceFactory.java Wed Mar 21 05:11:40 2007
@@ -20,8 +20,10 @@
package org.apache.synapse.core.axis2;
import org.apache.axis2.AxisFault;
+import org.apache.axis2.wsdl.WSDLConstants;
import org.apache.axis2.util.CallbackReceiver;
import org.apache.axis2.description.AxisService;
+import org.apache.axis2.description.AxisMessage;
import org.apache.axis2.engine.AxisConfiguration;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
@@ -128,6 +130,12 @@
DynamicAxisOperation dynamicOperation =
new DynamicAxisOperation(new QName(DYNAMIC_OPERATION));
dynamicOperation.setMessageReceiver(synapseCallback);
+ AxisMessage inMsg = new AxisMessage();
+ inMsg.setName("in-message");
+ AxisMessage outMsg = new AxisMessage();
+ outMsg.setName("out-message");
+ dynamicOperation.addMessage(inMsg, WSDLConstants.MESSAGE_LABEL_OUT_VALUE);
+ dynamicOperation.addMessage(outMsg, WSDLConstants.MESSAGE_LABEL_IN_VALUE);
AxisService axisAnonymousService = new AxisService(serviceKey);
axisAnonymousService.addOperation(dynamicOperation);
axisCfg.addService(axisAnonymousService);
Modified: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2FlexibleMEPClient.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2FlexibleMEPClient.java?view=diff&rev=520851&r1=520850&r2=520851
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2FlexibleMEPClient.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2FlexibleMEPClient.java Wed Mar 21 05:11:40 2007
@@ -30,6 +30,7 @@
import org.apache.axiom.soap.SOAPHeader;
import org.apache.axiom.soap.SOAPHeaderBlock;
import org.apache.axis2.AxisFault;
+import org.apache.axis2.wsdl.WSDLConstants;
import org.apache.axis2.addressing.AddressingConstants;
import org.apache.axis2.client.OperationClient;
import org.apache.axis2.client.Options;
@@ -165,6 +166,8 @@
OperationClient mepClient = axisAnonymousOperation.createClient(
serviceCtx, clientOptions);
mepClient.addMessageContext(axisOutMsgCtx);
+ axisOutMsgCtx.setAxisMessage(
+ axisAnonymousOperation.getMessage(WSDLConstants.MESSAGE_LABEL_OUT_VALUE));
// always set a callback as we decide if the send it blocking or non blocking within
// the MEP client. This does not cause an overhead, as we simply create a 'holder'
Modified: webservices/synapse/trunk/java/modules/nhttp/src/org/apache/axis2/transport/nhttp/ClientWorker.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/nhttp/src/org/apache/axis2/transport/nhttp/ClientWorker.java?view=diff&rev=520851&r1=520850&r2=520851
==============================================================================
--- webservices/synapse/trunk/java/modules/nhttp/src/org/apache/axis2/transport/nhttp/ClientWorker.java (original)
+++ webservices/synapse/trunk/java/modules/nhttp/src/org/apache/axis2/transport/nhttp/ClientWorker.java Wed Mar 21 05:11:40 2007
@@ -22,6 +22,7 @@
import org.apache.axis2.context.MessageContext;
import org.apache.axis2.description.WSDL2Constants;
import org.apache.axis2.AxisFault;
+import org.apache.axis2.wsdl.WSDLConstants;
import org.apache.axis2.engine.AxisEngine;
import org.apache.axis2.transport.TransportUtils;
import org.apache.axiom.soap.SOAPEnvelope;
@@ -99,6 +100,8 @@
responseMsgCtx.setProperty(MessageContext.TRANSPORT_HEADERS, headerMap);
}
+ responseMsgCtx.setAxisMessage(outMsgCtx.getOperationContext().getAxisOperation().
+ getMessage(WSDLConstants.MESSAGE_LABEL_IN_VALUE));
responseMsgCtx.setOperationContext(outMsgCtx.getOperationContext());
responseMsgCtx.setConfigurationContext(outMsgCtx.getConfigurationContext());
//responseMsgCtx.getOptions().setRelationships(
Modified: webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_50.xml
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_50.xml?view=diff&rev=520851&r1=520850&r2=520851
==============================================================================
--- webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_50.xml (original)
+++ webservices/synapse/trunk/java/repository/conf/sample/synapse_sample_50.xml Wed Mar 21 05:11:40 2007
@@ -17,32 +17,27 @@
~ under the License.
-->
-<synapse xmlns="http://ws.apache.org/ns/synapse">
+<definitions xmlns="http://ws.apache.org/ns/synapse">
<!-- Connecting to endpoints with WS-Security for outgoing messages -->
- <definitions>
- <set-property name="sec_policy" src="file:repository/conf/sample/resources/policy/policy_3.xml"/>
-
- <endpoint name="secure">
- <address uri="http://localhost:9000/axis2/services/SecureStockQuoteService3">
- <enableSec policy="sec_policy"/>
- <enableAddressing/>
- </address>
- </endpoint>
- </definitions>
+ <localEntry key="sec_policy" src="file:repository/conf/sample/resources/policy/policy_3.xml"/>
- <rules>
- <in>
- <header name="To" value="http://localhost:9000/axis2/services/SecureStockQuoteService3"/>
+ <endpoint name="secure">
+ <address uri="http://localhost:9000/axis2/services/SecureStockQuoteService3">
+ <enableSec policy="sec_policy"/>
+ <enableAddressing/>
+ </address>
+ </endpoint>
+
+ <in>
<send>
- <endpoint ref="secure"/>
+ <endpoint key="secure"/>
</send>
- </in>
- <out>
- <header name="wsse:Security" action="remove"
- xmlns:wsse="http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-secext-1.0.xsd"/>
- <send/>
- </out>
- </rules>
+ </in>
+ <out>
+ <header name="wsse:Security" action="remove"
+ xmlns:wsse="http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-secext-1.0.xsd"/>
+ <send/>
+ </out>
-</synapse>
\ No newline at end of file
+</definitions>
---------------------------------------------------------------------
To unsubscribe, e-mail: synapse-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: synapse-dev-help@ws.apache.org