Author: mckierna
Date: Mon Jun 4 04:45:07 2007
New Revision: 544129
URL: http://svn.apache.org/viewvc?view=rev&rev=544129
Log:
Ensure makeConnection mandate is only if we are running sync
Modified:
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java
Modified:
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java?view=diff&rev=544129&r1=544128&r2=544129
==============================================================================
---
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java
(original)
+++
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java
Mon Jun 4 04:45:07 2007
@@ -215,10 +215,14 @@
specVersion = rmsBean.getRMVersion();
}
if(specVersion ==
Sandesha2Constants.SPEC_VERSIONS.v1_1) {
- SandeshaPolicyBean policy =
SandeshaUtil.getPropertyBean(configContext.getAxisConfiguration());
- if(!policy.isEnableMakeConnection()) {
- String message =
SandeshaMessageHelper.getMessage(SandeshaMessageKeys.makeConnectionDisabled);
- throw new
SandeshaException(message);
+ EndpointReference replyTo =
msgContext.getReplyTo();
+ if(replyTo == null ||
replyTo.hasAnonymousAddress()) {
+ //we are sync
+ SandeshaPolicyBean policy =
SandeshaUtil.getPropertyBean(configContext.getAxisConfiguration());
+
if(!policy.isEnableMakeConnection()) {
+ String message =
SandeshaMessageHelper.getMessage(SandeshaMessageKeys.makeConnectionDisabled);
+ throw new
SandeshaException(message);
+ }
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
