User: hiram
Date: 00/11/13 21:57:34
Modified: src/java/org/spydermq ConnectionQueue.java
Log:
Fixed the deadlock in p2p messaging
Revision Changes Path
1.4 +14 -13 spyderMQ/src/java/org/spydermq/ConnectionQueue.java
Index: ConnectionQueue.java
===================================================================
RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/ConnectionQueue.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- ConnectionQueue.java 2000/06/05 03:19:23 1.3
+++ ConnectionQueue.java 2000/11/14 05:57:33 1.4
@@ -16,7 +16,7 @@
*
* @author Norbert Lataille ([EMAIL PROTECTED])
*
- * @version $Revision: 1.3 $
+ * @version $Revision: 1.4 $
*/
public class ConnectionQueue
{
@@ -70,20 +70,21 @@
if (connection.modeStop) return;
- try {
-
- if (val==-1&&NumListeningSessions==0) {
-
connection.provider.connectionListening(false,destination,connection.distributedConnection);
- } else if (val==1&&NumListeningSessions==1) {
-
connection.provider.connectionListening(true,destination,connection.distributedConnection);
- }
-
- } catch (Exception e) {
- connection.failureHandler(e,"Cannot contact the JMS
server");
+ }
+
+ try {
+
+ if (val==-1&&NumListeningSessions==0) {
+
connection.provider.connectionListening(false,destination,connection.distributedConnection);
+ } else if (val==1&&NumListeningSessions==1) {
+
connection.provider.connectionListening(true,destination,connection.distributedConnection);
}
- }
+
+ } catch (Exception e) {
+ connection.failureHandler(e,"Cannot contact the JMS server");
+ }
}
-
+
synchronized void start() throws JMSException
{
try {
