| | |
| | | catch (Exception e) |
| | | { |
| | | logger.traceException(e); |
| | | |
| | | logger.warn(WARN_QUEUE_UNABLE_TO_CANCEL.get(String.valueOf(o), |
| | | String.valueOf(e))); |
| | | logger.warn(WARN_QUEUE_UNABLE_TO_CANCEL.get(o, e)); |
| | | } |
| | | } |
| | | |
| | |
| | | catch (Exception e) |
| | | { |
| | | logger.traceException(e); |
| | | |
| | | logger.warn(WARN_QUEUE_UNABLE_TO_NOTIFY_THREAD.get(t.getName(), |
| | | String.valueOf(e))); |
| | | logger.warn(WARN_QUEUE_UNABLE_TO_NOTIFY_THREAD.get(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(), String.valueOf(ie))); |
| | | logger.warn(WARN_WORKER_INTERRUPTED_WITHOUT_SHUTDOWN.get(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(), String.valueOf(e))); |
| | | logger.warn(WARN_WORKER_WAITING_UNCAUGHT_EXCEPTION.get(Thread.currentThread().getName(), e)); |
| | | } |
| | | finally |
| | | { |