From 67a2cb9fe4149dc9d6cd750b3426995033ea9d9d Mon Sep 17 00:00:00 2001 From: Keith Wall Date: Mon, 16 Mar 2015 16:52:32 +0000 Subject: QPID-6429, QPID-6262: [Java Broker] Improve error handling in new NIO code; Remove MINA terminlogy (session etc) in 0-8 stack * Also added uncaught exception handler in test framework (QBTC) to guard log the case where a thread exits abnormally. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667068 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/qpid/test/utils/InternalBrokerHolder.java | 15 +++++++++++++++ 1 file changed, 15 insertions(+) (limited to 'qpid/java/systests/src') diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/InternalBrokerHolder.java b/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/InternalBrokerHolder.java index 4965f54403..3c3276c87a 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/InternalBrokerHolder.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/InternalBrokerHolder.java @@ -49,6 +49,21 @@ public class InternalBrokerHolder implements BrokerHolder @Override public void start(BrokerOptions options) throws Exception { + if (Thread.getDefaultUncaughtExceptionHandler() != null) + { + Thread.setDefaultUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() + { + @Override + public void uncaughtException(final Thread t, final Throwable e) + { + System.err.print("Thread terminated due to uncaught exception"); + e.printStackTrace(); + + LOGGER.error("Uncaught exception from thread " + t.getName(), e); + } + }); + } + LOGGER.info("Starting internal broker (same JVM)"); _broker = new Broker(new Action() -- cgit v1.2.1