Author: rhs
Date: Fri Jun 6 14:43:00 2008
New Revision: 664140
URL: http://svn.apache.org/viewvc?rev=664140&view=rev
Log:
QPID-1125: log exceptions destined to be swallowed by MINA
Modified:
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java
Modified:
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java?rev=664140&r1=664139&r2=664140&view=diff
==============================================================================
---
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java
(original)
+++
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java
Fri Jun 6 14:43:00 2008
@@ -46,6 +46,8 @@
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 @@
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)
