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/08/21 12:15:15 UTC
svn commit: r433217 - in
/webservices/sandesha/trunk/java/src/org/apache/sandesha2:
handlers/SandeshaOutHandler.java storage/Transaction.java
Author: chamikara
Date: Mon Aug 21 03:15:14 2006
New Revision: 433217
URL: http://svn.apache.org/viewvc?rev=433217&view=rev
Log:
A correction to the MessageProcessor selection logic.
Thanks Thomas for pointing this out.
Modified:
webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java
webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/Transaction.java
Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java?rev=433217&r1=433216&r2=433217&view=diff
==============================================================================
--- webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java (original)
+++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java Mon Aug 21 03:15:14 2006
@@ -113,16 +113,16 @@
if (messageType == Sandesha2Constants.MessageTypes.UNKNOWN) {
MessageContext requestMsgCtx = msgCtx.getOperationContext().getMessageContext(
OperationContextFactory.MESSAGE_LABEL_IN_VALUE);
- if (requestMsgCtx != null) { // for the server side
- RMMsgContext reqRMMsgCtx = MsgInitializer.initializeMessage(requestMsgCtx);
- Sequence sequencePart = (Sequence) reqRMMsgCtx
- .getMessagePart(Sandesha2Constants.MessageParts.SEQUENCE);
- if (sequencePart != null)
- msgProcessor = new ApplicationMsgProcessor();// a rm
- // intended
- // message.
- } else if (!msgCtx.isServerSide()) // if client side.
- msgProcessor = new ApplicationMsgProcessor();
+
+ if (msgCtx.isServerSide()) { // for the server side
+ RMMsgContext reqRMMsgCtx = MsgInitializer.initializeMessage(requestMsgCtx);
+ Sequence sequencePart = (Sequence) reqRMMsgCtx
+ .getMessagePart(Sandesha2Constants.MessageParts.SEQUENCE);
+ if (sequencePart != null)
+ msgProcessor = new ApplicationMsgProcessor();// a rm intended message
+ } else // if client side.
+ msgProcessor = new ApplicationMsgProcessor();
+
} else {
msgProcessor = MsgProcessorFactory.getMessageProcessor(rmMsgCtx);
}
Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/Transaction.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/Transaction.java?rev=433217&r1=433216&r2=433217&view=diff
==============================================================================
--- webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/Transaction.java (original)
+++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/Transaction.java Mon Aug 21 03:15:14 2006
@@ -29,4 +29,5 @@
//indicates that the transaction has been started, but has not been committed or rolledbacked yet.
public boolean isActive ();
+
}
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org