ws-sandesha-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mckie...@apache.org
Subject svn commit: r685498 - /webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/workers/Sender.java
Date Wed, 13 Aug 2008 10:12:44 GMT
Author: mckierna
Date: Wed Aug 13 03:12:41 2008
New Revision: 685498

URL: http://svn.apache.org/viewvc?rev=685498&view=rev
Log:
See https://issues.apache.org/jira/browse/SANDESHA2-175, thx Sara

Modified:
    webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/workers/Sender.java

Modified: webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/workers/Sender.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/workers/Sender.java?rev=685498&r1=685497&r2=685498&view=diff
==============================================================================
--- webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/workers/Sender.java
(original)
+++ webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/workers/Sender.java
Wed Aug 13 03:12:41 2008
@@ -178,13 +178,13 @@
 				}
 
 			} else {
-				RMDBean matcher = new RMDBean();
-				matcher.setSequenceID(sequenceId);
-				matcher.setTerminated(false);
-				RMDBean rmd = storageManager.getRMDBeanMgr().findUnique(matcher);
+				RMDBean rmd = SandeshaUtil.getRMDBeanFromSequenceId(storageManager, sequenceId);
 				if (rmd != null) {
-					found = true;
-					rmVersion = rmd.getRMVersion();
+					if (!rmd.isTerminated()) {
+						found = true;
+						rmVersion = rmd.getRMVersion();
+					}
+
 				}
 			}
 			if (!found) {



---------------------------------------------------------------------
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