jaliya 2005/06/07 20:47:10
Modified: sandesha/src/org/apache/sandesha/server RMInvokerWorker.java
ServerStorageManager.java
Log:
Fixed some synchronization problem in the worker
Revision Changes Path
1.2 +1 -1
ws-fx/sandesha/src/org/apache/sandesha/server/RMInvokerWorker.java
Index: RMInvokerWorker.java
===================================================================
RCS file:
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/server/RMInvokerWorker.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- RMInvokerWorker.java 29 May 2005 11:22:04 -0000 1.1
+++ RMInvokerWorker.java 8 Jun 2005 03:47:10 -0000 1.2
@@ -40,7 +40,7 @@
}
- public void run() {
+ public synchronized void run() {
while (true) {
try {
Thread.sleep(Constants.RMINVOKER_SLEEP_TIME);
1.35 +1 -1
ws-fx/sandesha/src/org/apache/sandesha/server/ServerStorageManager.java
Index: ServerStorageManager.java
===================================================================
RCS file:
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/server/ServerStorageManager.java,v
retrieving revision 1.34
retrieving revision 1.35
diff -u -r1.34 -r1.35
--- ServerStorageManager.java 6 Jun 2005 18:23:32 -0000 1.34
+++ ServerStorageManager.java 8 Jun 2005 03:47:10 -0000 1.35
@@ -61,7 +61,7 @@
* that is using this. Every thread just have to create an instance of
* ServerStorageManager and keep calling getNextMessageToProcess() and
* processing messages. The method will try to give the messages from the
- * same sequence id. But if that doesnt hv processable messages it will
go 4
+ * same sequence id. But if that doesnt hv processable messages it will
go for
* a new sequence.
*/
public RMMessageContext getNextMessageToProcess() {
