svn commit: r685498 - /webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/workers/Sender.java

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