You are viewing a plain text version of this content. The canonical link for it is here.
Posted to sandesha-dev@ws.apache.org by mc...@apache.org on 2007/06/04 13:45:08 UTC
svn commit: r544129 -
/webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java
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: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org