AgentTest.java

import uk.co.real_logic.agrona.ErrorHandler;
import uk.co.real_logic.agrona.concurrent.Agent;
import uk.co.real_logic.agrona.concurrent.AgentRunner;
import uk.co.real_logic.agrona.concurrent.BusySpinIdleStrategy;

public class AgentTest {
	
	static class SomeAgent implements Agent {

		@Override
		public int doWork() throws Exception {
			throw new RuntimeException("Error");	
		}

		@Override
		public String roleName() {
			return "SomeAgent";
		}
		
		@Override
		public void onClose() {
			System.out.println("This is never called");
		}
		
	}
	
	static class RunOnError implements ErrorHandler {
		private Runnable r;
		
		void action(Runnable r) {
			this.r = r;
		}
		
		@Override
		public void onError(Throwable throwable) {
			r.run();
		}
	}
	
	public static void main(String[] args) throws Exception {

		RunOnError closeOnError = new RunOnError();

		AgentRunner agentRunner = new AgentRunner(new BusySpinIdleStrategy(), closeOnError, null, new SomeAgent());
		
		closeOnError.action(agentRunner::close);

		AgentRunner.startOnThread(agentRunner);
								
	}
}