| /* |
| * |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| /* |
| * |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| * |
| */ |
| package org.apache.qpid.test.framework; |
| |
| import org.apache.log4j.Logger; |
| |
| import javax.jms.ExceptionListener; |
| import javax.jms.JMSException; |
| import java.io.PrintWriter; |
| import java.io.StringWriter; |
| import java.util.ArrayList; |
| import java.util.List; |
| |
| /** |
| * An exception monitor, listens for JMS exception on a connection or consumer. It record all exceptions that it receives |
| * and provides methods to test the number and type of exceptions received. |
| * |
| * <p/><table id="crc"><caption>CRC Card</caption> |
| * <tr><th> Responsibilities <th> Collaborations |
| * <tr><td> Record all exceptions received. |
| * </table> |
| */ |
| public class ExceptionMonitor implements ExceptionListener |
| { |
| /** Used for debugging. */ |
| private final Logger log = Logger.getLogger(ExceptionMonitor.class); |
| |
| /** Holds the received exceptions. */ |
| private List<Exception> exceptions = new ArrayList<Exception>(); |
| |
| /** |
| * Receives incoming exceptions. |
| * |
| * @param e The exception to record. |
| */ |
| public synchronized void onException(JMSException e) |
| { |
| log.debug("public void onException(JMSException e): called", e); |
| |
| exceptions.add(e); |
| } |
| |
| /** |
| * Checks that no exceptions have been received. |
| * |
| * @return <tt>true</tt> if no exceptions have been received, <tt>false</tt> otherwise. |
| */ |
| public synchronized boolean assertNoExceptions() |
| { |
| return exceptions.isEmpty(); |
| } |
| |
| /** |
| * Checks that exactly one exception has been received. |
| * |
| * @return <tt>true</tt> if exactly one exception been received, <tt>false</tt> otherwise. |
| */ |
| public synchronized boolean assertOneJMSException() |
| { |
| return exceptions.size() == 1; |
| } |
| |
| /** |
| * Checks that exactly one exception, with a linked cause of the specified type, has been received. |
| * |
| * @param aClass The type of the linked cause. |
| * |
| * @return <tt>true</tt> if exactly one exception, with a linked cause of the specified type, been received, |
| * <tt>false</tt> otherwise. |
| */ |
| public synchronized boolean assertOneJMSExceptionWithLinkedCause(Class aClass) |
| { |
| if (exceptions.size() == 1) |
| { |
| Exception e = exceptions.get(0); |
| |
| if (e instanceof JMSException) |
| { |
| JMSException jmse = (JMSException) e; |
| |
| Exception linkedCause = jmse.getLinkedException(); |
| |
| if ((linkedCause != null) && aClass.isInstance(linkedCause)) |
| { |
| return true; |
| } |
| } |
| } |
| |
| return false; |
| } |
| |
| /** |
| * Checks that at least one exception of the the specified type, has been received. |
| * |
| * @param exceptionClass The type of the exception. |
| * |
| * @return <tt>true</tt> if at least one exception of the specified type has been received, <tt>false</tt> otherwise. |
| */ |
| public synchronized boolean assertExceptionOfType(Class exceptionClass) |
| { |
| // Start by assuming that the exception has no been received. |
| boolean passed = false; |
| |
| // Scan all the exceptions for a match. |
| for (Exception e : exceptions) |
| { |
| if (exceptionClass.isInstance(e)) |
| { |
| passed = true; |
| |
| break; |
| } |
| } |
| |
| return passed; |
| } |
| |
| /** |
| * Reports the number of exceptions held by this monitor. |
| * |
| * @return The number of exceptions held by this monitor. |
| */ |
| public synchronized int size() |
| { |
| return exceptions.size(); |
| } |
| |
| /** |
| * Clears the record of received exceptions. |
| */ |
| public synchronized void reset() |
| { |
| exceptions = new ArrayList<Exception>(); |
| } |
| |
| /** |
| * Provides a dump of the stack traces of all exceptions that this exception monitor was notified of. Mainly |
| * use for debugging/test failure reporting purposes. |
| * |
| * @return A string containing a dump of the stack traces of all exceptions. |
| */ |
| public synchronized String toString() |
| { |
| String result = "ExceptionMonitor: holds " + exceptions.size() + " exceptions.\n\n"; |
| |
| for (Exception ex : exceptions) |
| { |
| result += getStackTrace(ex) + "\n"; |
| } |
| |
| return result; |
| } |
| |
| /** |
| * Prints an exception stack trace into a string. |
| * |
| * @param t The throwable to get the stack trace from. |
| * |
| * @return A string containing the throwables stack trace. |
| */ |
| public static String getStackTrace(Throwable t) |
| { |
| StringWriter sw = new StringWriter(); |
| PrintWriter pw = new PrintWriter(sw, true); |
| t.printStackTrace(pw); |
| pw.flush(); |
| sw.flush(); |
| |
| return sw.toString(); |
| } |
| } |