diff options
author | Rafael H. Schloming <rhs@apache.org> | 2008-06-06 21:43:00 +0000 |
---|---|---|
committer | Rafael H. Schloming <rhs@apache.org> | 2008-06-06 21:43:00 +0000 |
commit | c8ba232edc8ad28edb70395ea7b33cba90bd08a0 (patch) | |
tree | dbc8c2c58e3e51a9d3f7a505960186d47031aa91 /qpid/java/common | |
parent | 43c5913f8d4a7edb5a1d42c58da90fe641f11fb1 (diff) | |
download | qpid-python-c8ba232edc8ad28edb70395ea7b33cba90bd08a0.tar.gz |
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
Diffstat (limited to 'qpid/java/common')
-rw-r--r-- | qpid/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java | 13 |
1 files changed, 11 insertions, 2 deletions
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<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) |