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 ch...@apache.org on 2006/09/07 16:49:24 UTC
svn commit: r441102 - in
/webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers:
Invoker.java Sender.java
Author: chamikara
Date: Thu Sep 7 07:49:24 2006
New Revision: 441102
URL: http://svn.apache.org/viewvc?view=rev&rev=441102
Log:
A bug fix in the sender and invoker.
Modified:
webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/Invoker.java
webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/Sender.java
Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/Invoker.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/Invoker.java?view=diff&rev=441102&r1=441101&r2=441102
==============================================================================
--- webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/Invoker.java (original)
+++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/Invoker.java Thu Sep 7 07:49:24 2006
@@ -258,8 +258,6 @@
continue;
}
- lock.addWork(workId);
-
InvokerBean bean = (InvokerBean) stMapIt.next();
String messageContextKey = bean.getMessageContextRefKey();
@@ -272,6 +270,10 @@
worker.setWorkId(workId);
threadPool.execute(worker);
+
+ //adding the workId to the lock after assigning it to a thread makes sure
+ //that all the workIds in the Lock are handled by threads.
+ lock.addWork(workId);
}
} catch (Exception e) {
Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/Sender.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/Sender.java?view=diff&rev=441102&r1=441101&r2=441102
==============================================================================
--- webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/Sender.java (original)
+++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/Sender.java Thu Sep 7 07:49:24 2006
@@ -189,8 +189,6 @@
log.debug(message);
continue;
}
-
- lock.addWork(workId);
transaction.commit();
@@ -199,6 +197,10 @@
worker.setLock (lock);
worker.setWorkId(messageId);
threadPool.execute(worker);
+
+ //adding the workId to the lock after assigning it to a thread makes sure
+ //that all the workIds in the Lock are handled by threads.
+ lock.addWork(workId);
} catch (Exception e) {
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org