}

        @Override
        public Process getProcess() {
            return new TestProcess(exitValue);
        }

        @Override
        public InputStreamThread getInputStreamThread() {
            return new TestInputStreamThread(output);
        }
    }

    private static class TestProcess extends Process {
        private final int exitValue;

        }

        @Override
        public Process getProcess() {
            return new TestProcess(exitValue);
        }

        @Override
        public InputStreamThread getInputStreamThread() {
            return new TestInputStreamThread(output);
        }
    }

    private static class TestProcess extends Process {
        private final int exitValue;

            super(new MockProcess(exitValue));
            this.exitValue = exitValue;
            this.output = output;
        }

        @Override
        public InputStreamThread getInputStreamThread() {
            return new MockInputStreamThread(output);
        }

        @Override
        public Process getProcess() {
            return new MockProcess(exitValue);
        }
    }

                pb.directory(baseDir);
                pb.redirectErrorStream(true);
            });

            final InputStreamThread it = jobProcess.getInputStreamThread();
            it.start();

            final Process currentProcess = jobProcess.getProcess();
            currentProcess.waitFor();
            it.join(5000);

                pb.directory(baseDir);
                pb.redirectErrorStream(true);
            });

            final InputStreamThread it = jobProcess.getInputStreamThread();
            it.start();

            final Process currentProcess = jobProcess.getProcess();
            currentProcess.waitFor();
            it.join(5000);

     */
    protected int destroyProcess(final String sessionId, final JobProcess jobProcess) {
        if (jobProcess != null) {
            final InputStreamThread ist = jobProcess.getInputStreamThread();
            try {
                ist.interrupt();
            } catch (final Exception e) {
                logger.warn("Could not interrupt a thread of an input stream.", e);
            }

                pb.directory(baseDir);
                pb.redirectErrorStream(true);
            });

            final InputStreamThread it = jobProcess.getInputStreamThread();
            it.start();

            final Process currentProcess = jobProcess.getProcess();
            currentProcess.waitFor();
            it.join(5000);