ws-sandesha-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mckie...@apache.org
Subject svn commit: r544129 - /webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java
Date Mon, 04 Jun 2007 11:45:08 GMT
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


Mime
View raw message