[jboss-cvs] JBoss Messaging SVN: r4810 - trunk/src/main/org/jboss/messaging/core/remoting/impl/netty.

[jboss-cvs-commits at lists.jboss.org]

Author: trustin
Date: 2008-08-18 03:58:07 -0400 (Mon, 18 Aug 2008)
New Revision: 4810

Modified:
   trunk/src/main/org/jboss/messaging/core/remoting/impl/netty/NettyAcceptor.java
   trunk/src/main/org/jboss/messaging/core/remoting/impl/netty/NettyConnector.java
Log:
Made sure that an exception doesn't cause infinite recursion in NettyAcceptor and NettyConnector.

Modified: trunk/src/main/org/jboss/messaging/core/remoting/impl/netty/NettyAcceptor.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/impl/netty/NettyAcceptor.java	2008-08-18 07:45:49 UTC (rev 4809)
+++ trunk/src/main/org/jboss/messaging/core/remoting/impl/netty/NettyAcceptor.java	2008-08-18 07:58:07 UTC (rev 4810)
@@ -166,7 +166,11 @@
                e.getChannel(), e.getCause());
          MessagingException me = new MessagingException(MessagingException.INTERNAL_ERROR, "Netty exception");
          me.initCause(e.getCause());
-         listener.connectionException(e.getChannel().getId(), me);
+         try {
+            listener.connectionException(e.getChannel().getId(), me);
+         } catch (Exception ex) {
+            log.error("failed to notify the listener:", ex);
+         }
       }
 
       @Override

Modified: trunk/src/main/org/jboss/messaging/core/remoting/impl/netty/NettyConnector.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/impl/netty/NettyConnector.java	2008-08-18 07:45:49 UTC (rev 4809)
+++ trunk/src/main/org/jboss/messaging/core/remoting/impl/netty/NettyConnector.java	2008-08-18 07:58:07 UTC (rev 4810)
@@ -226,7 +226,11 @@
 
          MessagingException me = new MessagingException(MessagingException.INTERNAL_ERROR, "Netty exception");
          me.initCause(e.getCause());
-         listener.connectionException(e.getChannel().getId(), me);
+         try {
+            listener.connectionException(e.getChannel().getId(), me);
+         } catch (Exception ex) {
+            log.error("failed to notify the listener:", ex);
+         }
       }
    }
 }