User: hiram
Date: 01/02/13 16:42:52
Modified: src/main/org/jbossmq/distributed/server
ConnectionReceiverUIL.java
ConnectionReceiverOIL.java
Log:
Bug Fix: Report: "I have tried to set an exception listener on the connection, but
it is
not called. Have I missed someting here? Should not a JMS
implementation call any exception listeners when a connection error is
discovered?"
by Peter
Revision Changes Path
1.2 +7 -5
jbossmq/src/main/org/jbossmq/distributed/server/ConnectionReceiverUIL.java
Index: ConnectionReceiverUIL.java
===================================================================
RCS file:
/products/cvs/ejboss/jbossmq/src/main/org/jbossmq/distributed/server/ConnectionReceiverUIL.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- ConnectionReceiverUIL.java 2001/01/26 00:43:41 1.1
+++ ConnectionReceiverUIL.java 2001/02/14 00:42:51 1.2
@@ -52,7 +52,7 @@
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.1 $
+ * @version $Revision: 1.2 $
*/
public class ConnectionReceiverUIL implements Runnable,
org.jbossmq.distributed.interfaces.ConnectionReceiverSetup {
// Attributes ----------------------------------------------------
@@ -163,15 +163,17 @@
out.close();
in.close();
} catch (IOException e) {
- Log.log("Error whle closing receiver connections ");
- Log.log(e);
+ failure("Error whle closing receiver connections", e);
return;
}
}
void failure(String st, Exception e) {
- Log.error("Closing socket: " + st);
- Log.error(e);
+ try {
+ connection.failureHandler(e, st);
+ } catch (JMSException ex) {
+ //Will allways come here
+ }
}
// Public --------------------------------------------------------
1.2 +7 -5
jbossmq/src/main/org/jbossmq/distributed/server/ConnectionReceiverOIL.java
Index: ConnectionReceiverOIL.java
===================================================================
RCS file:
/products/cvs/ejboss/jbossmq/src/main/org/jbossmq/distributed/server/ConnectionReceiverOIL.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- ConnectionReceiverOIL.java 2001/01/26 00:43:41 1.1
+++ ConnectionReceiverOIL.java 2001/02/14 00:42:52 1.2
@@ -53,7 +53,7 @@
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.1 $
+ * @version $Revision: 1.2 $
*/
public class ConnectionReceiverOIL implements Runnable,
org.jbossmq.distributed.interfaces.ConnectionReceiverSetup {
// Attributes ----------------------------------------------------
@@ -167,15 +167,17 @@
out.close();
in.close();
} catch (IOException e) {
- Log.log("Error whle closing receiver connections ");
- Log.log(e);
+ failure("Error whle closing receiver connections", e);
return;
}
}
void failure(String st, Exception e) {
- Log.error("Closing socket: " + st);
- Log.error(e);
+ try {
+ connection.failureHandler(e, st);
+ } catch (JMSException ex) {
+ //Will allways come here
+ }
}
public void setConnection(SpyConnection connection) {
