[prev in list] [next in list] [prev in thread] [next in thread] 

List:       sandesha-dev
Subject:    svn commit: r385342 - in
From:       chamikara () apache ! org
Date:       2006-03-12 18:50:59
Message-ID: 20060312185100.98648.qmail () minotaur ! apache ! org
[Download RAW message or body]

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


[prev in list] [next in list] [prev in thread] [next in thread]