(Throwable exception)
| 267 | } |
| 268 | |
| 269 | private void die(Throwable exception) { |
| 270 | String processInfo = process.getProcessInfoString() + process.getProcessTerminationInfoString(); |
| 271 | this.exception = new RuntimeException(processInfo, exception); |
| 272 | String message = String.format("Halting process: ShellSpout died. Command: %s, ProcessInfo %s", |
| 273 | Arrays.toString(command), |
| 274 | processInfo); |
| 275 | LOG.error(message, exception); |
| 276 | collector.reportError(exception); |
| 277 | if (running || (exception instanceof Error)) { //don't exit if not running, unless it is an Error |
| 278 | System.exit(11); |
| 279 | } |
| 280 | } |
| 281 | |
| 282 | private class SpoutHeartbeatTimerTask extends TimerTask { |
| 283 | private ShellSpout spout; |
no test coverage detected