| | |
| | | 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)); |
| | | } |
| | | } |
| | | } |
| | |
| | | |
| | | // 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)); |
| | | return retryNextOperation(workerThread, numFailures + 1); |
| | | } |
| | | } |