ws-sandesha-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chamik...@apache.org
Subject svn commit: r312543 - in /webservices/sandesha/trunk/src/org/apache/sandesha2: handlers/SandeshaOutHandler.java msgprocessors/ApplicationMsgProcessor.java
Date Mon, 10 Oct 2005 04:34:02 GMT
Author: chamikara
Date: Sun Oct  9 21:33:09 2005
New Revision: 312543

URL: http://svn.apache.org/viewcvs?rev=312543&view=rev
Log:
CLIENT SIDE - following message exchange is working
--> create seq
<-- create seq response
--> msg1 
<-- acknwoledgement

Modified:
    webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java?rev=312543&r1=312542&r2=312543&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java Sun
Oct  9 21:33:09 2005
@@ -27,6 +27,7 @@
 import org.apache.axis2.handlers.AbstractHandler;
 import org.apache.axis2.soap.SOAPBody;
 import org.apache.axis2.soap.SOAPEnvelope;
+import org.apache.axis2.util.UUIDGenerator;
 import org.apache.sandesha2.Constants;
 import org.apache.sandesha2.MsgInitializer;
 import org.apache.sandesha2.SOAPAbstractFactory;
@@ -273,6 +274,19 @@
 					
 				}
 			}
+			
+			//Setting WSA Action if null
+			//TODO: Recheck weather this action is correct
+			if (msgCtx.getWSAAction()==null){
+				EndpointReference toEPR = msgCtx.getTo();
+				
+				if (toEPR==null)
+					throw new SandeshaException ("To EPR is not found");
+				
+				String to = toEPR.getAddress();
+				String operationName = msgCtx.getOperationContext().getAxisOperation().getName().getLocalPart();
+				msgCtx.setWSAAction(to + "/" + operationName);
+			}
 
 		} catch (SandeshaException e) {
 			throw new AxisFault(e.getMessage());
@@ -320,6 +334,14 @@
 			String tempSequenceId, long messageNumber) throws SandeshaException {
 
 		MessageContext msg = rmMsg.getMessageContext();
+		
+		//Changing message Id.
+		//TODO remove this when Axis2 start sending uuids as uuid:xxxx
+		String messageId = SandeshaUtil.getUUID();
+		rmMsg.setMessageId(messageId);
+		OperationContext opCtx = msg.getOperationContext();
+		msg.getSystemContext().registerOperationContext(messageId,opCtx);
+		
 
 		if (rmMsg == null)
 			throw new SandeshaException("Message or reques message is null");

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java?rev=312543&r1=312542&r2=312543&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java
(original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java
Sun Oct  9 21:33:09 2005
@@ -104,7 +104,7 @@
 
 			//TODO is this enough
 			msgCtx.setPausedTrue(new QName(Constants.IN_HANDLER_NAME));
-
+			
 		}
 
 		if (messagesStr != "" && messagesStr != null)



---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org


Mime
View raw message