(Throwable exception)
| 293 | } |
| 294 | |
| 295 | private void die(Throwable exception) { |
| 296 | String processInfo = process.getProcessInfoString() + process.getProcessTerminationInfoString(); |
| 297 | this.exception = new RuntimeException(processInfo, exception); |
| 298 | String message = String.format("Halting process: ShellBolt died. Command: %s, ProcessInfo %s", |
| 299 | Arrays.toString(command), |
| 300 | processInfo); |
| 301 | LOG.error(message, exception); |
| 302 | collector.reportError(exception); |
| 303 | if (!isLocalMode && (running || (exception instanceof Error))) { //don't exit if not running, unless it is an Error |
| 304 | System.exit(11); |
| 305 | } |
| 306 | } |
| 307 | |
| 308 | private class BoltHeartbeatTimerTask extends TimerTask { |
| 309 | private ShellBolt bolt; |
no test coverage detected