src/test/java/geode/kafka/WorkerAndHerderCluster.java

package geode.kafka;

import java.io.IOException;

public class WorkerAndHerderCluster {

    private JavaProcess workerAndHerder;

    public WorkerAndHerderCluster() {
        workerAndHerder = new JavaProcess(WorkerAndHerderWrapper.class);
    }

    public void start() throws IOException, InterruptedException {
        workerAndHerder.exec();

    }

    public void stop() {
        workerAndHerder.destroy();
    }
}