add an exception listener
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/04c5b8dc Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/04c5b8dc Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/04c5b8dc Branch: refs/heads/master Commit: 04c5b8dca8837a73f5f3fecece9d3edba84bd177 Parents: 4440130 Author: Robert Gemmell <[email protected]> Authored: Tue Feb 3 12:13:01 2015 +0000 Committer: Robert Gemmell <[email protected]> Committed: Tue Feb 3 12:13:01 2015 +0000 ---------------------------------------------------------------------- .../main/java/org/apache/qpid/jms/example/Drain.java | 12 ++++++++++++ 1 file changed, 12 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/04c5b8dc/qpid-jms-examples/src/main/java/org/apache/qpid/jms/example/Drain.java ---------------------------------------------------------------------- diff --git a/qpid-jms-examples/src/main/java/org/apache/qpid/jms/example/Drain.java b/qpid-jms-examples/src/main/java/org/apache/qpid/jms/example/Drain.java index 0c82c76..6754aea 100644 --- a/qpid-jms-examples/src/main/java/org/apache/qpid/jms/example/Drain.java +++ b/qpid-jms-examples/src/main/java/org/apache/qpid/jms/example/Drain.java @@ -25,6 +25,8 @@ import java.util.Properties; import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.Destination; +import javax.jms.ExceptionListener; +import javax.jms.JMSException; import javax.jms.MessageConsumer; import javax.jms.Session; import javax.jms.TextMessage; @@ -61,6 +63,7 @@ public class Drain { Destination queue = (Destination) context.lookup("myQueueLookup"); Connection connection = factory.createConnection(USER, PASSWORD); + connection.setExceptionListener(new MyExceptionListener()); connection.start(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); @@ -98,4 +101,13 @@ public class Drain { System.exit(1); } } + + private static class MyExceptionListener implements ExceptionListener { + @Override + public void onException(JMSException exception) { + System.out.println("Connection ExceptionListener fired, exiting."); + exception.printStackTrace(System.out); + System.exit(1); + } + } } \ No newline at end of file --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
