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 2008/08/13 12:12:44 UTC
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) {
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org