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