| | |
| | | catch (Exception e) |
| | | { |
| | | logger.traceException(e); |
| | | logger.warn(WARN_QUEUE_UNABLE_TO_CANCEL.get(o, e)); |
| | | logger.warn(WARN_QUEUE_UNABLE_TO_CANCEL, o, e); |
| | | } |
| | | } |
| | | |
| | |
| | | catch (Exception e) |
| | | { |
| | | logger.traceException(e); |
| | | logger.warn(WARN_QUEUE_UNABLE_TO_NOTIFY_THREAD.get(t.getName(), e)); |
| | | logger.warn(WARN_QUEUE_UNABLE_TO_NOTIFY_THREAD, t.getName(), e); |
| | | } |
| | | } |
| | | } |
| | |
| | | |
| | | // If we've gotten here, then the worker thread was interrupted for some |
| | | // other reason. This should not happen, and we need to log a message. |
| | | logger.warn(WARN_WORKER_INTERRUPTED_WITHOUT_SHUTDOWN.get(Thread.currentThread().getName(), ie)); |
| | | logger.warn(WARN_WORKER_INTERRUPTED_WITHOUT_SHUTDOWN, Thread.currentThread().getName(), ie); |
| | | } |
| | | catch (Exception e) |
| | | { |
| | |
| | | |
| | | // This should not happen. The only recourse we have is to log a message |
| | | // and try again. |
| | | logger.warn(WARN_WORKER_WAITING_UNCAUGHT_EXCEPTION.get(Thread.currentThread().getName(), e)); |
| | | logger.warn(WARN_WORKER_WAITING_UNCAUGHT_EXCEPTION, Thread.currentThread().getName(), e); |
| | | } |
| | | finally |
| | | { |