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: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
