You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by ch...@apache.org on 2006/03/12 19:50:59 UTC

svn commit: r385342 - in /webservices/sandesha/trunk/src/org/apache/sandesha2/handlers: SandeshaInHandler.java SandeshaOutHandler.java

Author: chamikara
Date: Sun Mar 12 10:50:58 2006
New Revision: 385342

URL: http://svn.apache.org/viewcvs?rev=385342&view=rev
Log:
with this, a RM service can be called by a non-RM client.

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

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaInHandler.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaInHandler.java?rev=385342&r1=385341&r2=385342&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaInHandler.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaInHandler.java Sun Mar 12 10:50:58 2006
@@ -85,9 +85,11 @@
 				.getMessageProcessor(rmMsgCtx.getMessageType());
 
 		if (msgProcessor == null) {
-			String message = "An Invalid RM message was received. Sandesha2 cant forward this request";
-			log.debug(message);
-			throw new AxisFault(message);
+//			String message = "An Invalid RM message was received. Sandesha2 cant forward this request";
+//			log.debug(message);
+//			throw new AxisFault(message);
+			
+			return;  //this is not a rm message
 		}
 
 		try {

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=385342&r1=385341&r2=385342&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java Sun Mar 12 10:50:58 2006
@@ -121,6 +121,16 @@
 		if (!(rmMsgCtx.getMessageType() == Sandesha2Constants.MessageTypes.UNKNOWN)) {
 			return;
 		}
+		
+		MessageContext requestMessageCtx = msgCtx.getOperationContext().getMessageContext(OperationContextFactory.MESSAGE_LABEL_IN_VALUE);
+		if (requestMessageCtx!=null) {
+			RMMsgContext reqRMMsgCtx = MsgInitializer.initializeMessage(requestMessageCtx);
+			Sequence reqSeqPart = (Sequence) reqRMMsgCtx.getMessagePart(Sandesha2Constants.MessageParts.SEQUENCE);
+			if (reqSeqPart==null) {
+				//this is not a rm intended message
+				return;
+			}
+		}
 
 		Parameter policyParam = msgCtx
 				.getParameter(Sandesha2Constants.SANDESHA2_POLICY_BEAN);



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