User: norbert
Date: 00/05/31 19:47:49
Modified: src/java/org/spydermq JMSServer.java JMSServerQueue.java
Log:
P2P : Fixes
Revision Changes Path
1.3 +6 -2 spyderMQ/src/java/org/spydermq/JMSServer.java
Index: JMSServer.java
===================================================================
RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/JMSServer.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- JMSServer.java 2000/06/01 00:04:40 1.2
+++ JMSServer.java 2000/06/01 02:47:48 1.3
@@ -22,7 +22,7 @@
*
* @author Norbert Lataille ([EMAIL PROTECTED])
*
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.3 $
*/
public class JMSServer
implements Runnable
@@ -106,7 +106,11 @@
}
//Ask the queue to do its job
- queue.doMyJob();
+ try {
+ queue.doMyJob();
+ } catch (JMSException e) {
+ Log.error(e);
+ }
}
1.7 +7 -3 spyderMQ/src/java/org/spydermq/JMSServerQueue.java
Index: JMSServerQueue.java
===================================================================
RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/JMSServerQueue.java,v
retrieving revision 1.6
retrieving revision 1.7
diff -u -r1.6 -r1.7
--- JMSServerQueue.java 2000/06/01 02:38:49 1.6
+++ JMSServerQueue.java 2000/06/01 02:47:48 1.7
@@ -18,7 +18,7 @@
*
* @author Norbert Lataille ([EMAIL PROTECTED])
*
- * @version $Revision: 1.6 $
+ * @version $Revision: 1.7 $
*/
public class JMSServerQueue
{
@@ -239,7 +239,7 @@
removeSubscriber(dc,i);
}
- void doMyJob()
+ void doMyJob() throws JMSException
{
if (isTopic) {
@@ -304,8 +304,12 @@
Log.error(e2);
}
+ } catch (JMSException e) {
+ throw e;
} catch (Exception e) {
-
+ //This is a transport failure. We should
define our own Transport Failure class
+ //to catch errors more precisely.
+
try {
addMessage(mes);
} catch (Exception e2) {
