private StreamGobbler errorGobbler;
private StreamGobbler outputGobbler;
private ProcessMXBean processMXBean;
+ private final Object terminationLock = new Object();
public ProcessWrapper(String processName) {
super(processName);
} catch (Exception e) {
LOGGER.info("ProcessThread has been interrupted. Killing node.");
LOGGER.trace("Process exception", e);
- } finally {
- ;
- ;
}
}
return null;
}
- private final Integer terminationLock = new Integer(1);
@Override
public void terminate() {
synchronized (terminationLock) {
private final boolean isBlocking;
private Node node;
- private final Integer lock = new Integer(1);
+ private final Object lock = new Object();
@VisibleForTesting
public SearchServer(final Props props, boolean monitored, boolean blocking) {