QPID-1125: log exceptions destined to be swallowed by MINA

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@664140 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 11 insertions, 2 deletions

diff --git a/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java b/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java
index 3021184842..6010755d7d 100644
--- a/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java
+++ b/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java
@@ -46,6 +46,8 @@ import org.apache.qpidity.transport.network.Disassembler;
 import org.apache.qpidity.transport.network.InputHandler;
 import org.apache.qpidity.transport.network.OutputHandler;
 
+import static org.apache.qpidity.transport.util.Functions.*;
+
 /**
  * MinaHandler
  *
@@ -74,12 +76,19 @@ public class MinaHandler<E> implements IoHandler
         this.binding = binding;
     }
 
-
     public void messageReceived(IoSession ssn, Object obj)
     {
         Attachment<E> attachment = (Attachment<E>) ssn.getAttachment();
         ByteBuffer buf = (ByteBuffer) obj;
-        attachment.receiver.received(buf.buf());
+        try
+        {
+            attachment.receiver.received(buf.buf());
+        }
+        catch (Throwable t)
+        {
+            log.error(t, "exception handling buffer %s", str(buf.buf()));
+            throw new RuntimeException(t);
+        }
     }
 
     public void messageSent(IoSession ssn, Object obj)