User: norbert
Date: 00/06/14 12:20:20
Modified: src/java/org/spydermq SpySession.java
SpyTopicSubscriber.java
Log:
Fix : mutex.notifyLock()
Revision Changes Path
1.4 +4 -4 spyderMQ/src/java/org/spydermq/SpySession.java
Index: SpySession.java
===================================================================
RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/SpySession.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- SpySession.java 2000/06/14 19:16:51 1.3
+++ SpySession.java 2000/06/14 19:20:19 1.4
@@ -28,7 +28,7 @@
*
* @author Norbert Lataille ([EMAIL PROTECTED])
*
- * @version $Revision: 1.3 $
+ * @version $Revision: 1.4 $
*/
public class SpySession
implements Runnable, Session
@@ -298,7 +298,7 @@
//We have finished our work, we can wake up the thread
modeStop=modeSav;
- mutex.notify();
+ mutex.notifyLock();
}
@@ -333,7 +333,7 @@
//We have finished our work, we can wake up the thread
modeStop=modeSav;
- mutex.notify();
+ mutex.notifyLock();
}
}
@@ -362,7 +362,7 @@
//We have finished our work, we can wake up the thread
modeStop=modeSav;
- mutex.notify();
+ mutex.notifyLock();
}
1.5 +2 -2 spyderMQ/src/java/org/spydermq/SpyTopicSubscriber.java
Index: SpyTopicSubscriber.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/SpyTopicSubscriber.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -u -r1.4 -r1.5
--- SpyTopicSubscriber.java 2000/06/14 19:16:51 1.4
+++ SpyTopicSubscriber.java 2000/06/14 19:20:19 1.5
@@ -19,7 +19,7 @@
*
* @author Norbert Lataille ([EMAIL PROTECTED])
*
- * @version $Revision: 1.4 $
+ * @version $Revision: 1.5 $
*/
public class SpyTopicSubscriber
extends SpyMessageConsumer
@@ -165,7 +165,7 @@
messageListener=listener;
//Signal the change to the session thread ( it could sleep, while
there are messages for him )
- session.mutex.notify();
+ session.mutex.notifyLock();
}