From c8ba232edc8ad28edb70395ea7b33cba90bd08a0 Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Fri, 6 Jun 2008 21:43:00 +0000 Subject: QPID-1125: log exceptions destined to be swallowed by MINA git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@664140 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/qpidity/transport/network/mina/MinaHandler.java | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) (limited to 'qpid/java') diff --git a/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java b/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java index 3021184842..6010755d7d 100644 --- a/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java +++ b/qpid/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 implements IoHandler this.binding = binding; } - public void messageReceived(IoSession ssn, Object obj) { Attachment attachment = (Attachment) 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) -- cgit v1.2.1