@Test(timeout = 60000)
public void testScheduledExecutorServiceSimpleSchedule() throws ExecutionException, InterruptedException {

	ScheduledExecutor scheduledExecutor = akkaRpcService.getScheduledExecutor();
	final OneShotLatch latch = new OneShotLatch();
	ScheduledFuture<?> future = scheduledExecutor.schedule(
		new Runnable() {
			@Override
			public void run() {
				latch.trigger();
			}
		},
		10L,
		TimeUnit.MILLISECONDS);
	future.get();
	// once the future is completed, then the latch should have been triggered
	assertTrue(latch.isTriggered());
}