@Test(expected=ExecutionException.class) public void testSetException() throws InterruptedException, ExecutionException { DistributedFuture<String, String> f = new DistributedFuture<String, String>(null, null, null); f.setException(new TestException()); f.get(); }
public boolean setException(Throwable e) { return super.setException(e); }
DistributedFuture extends AbstractFuture<V> { public boolean setException(Throwable e) { return super.setException(e); } }
DistributedFuture extends AbstractFuture<V> { public boolean setException(Throwable e) { return super.setException(e); } DistributedFuture(IExecutorTopologyService<GROUP> topologyService, GROUP group, UUID taskId); }
DistributedFuture extends AbstractFuture<V> { public boolean setException(Throwable e) { return super.setException(e); } DistributedFuture(IExecutorTopologyService<GROUP> topologyService, GROUP group, UUID taskId); @Override boolean cancel(boolean mayInterruptIfRunning); boolean setCancelled(boolean mayInterruptIfRunning); boolean setException(Throwable e); boolean set(V value); long getCreatedTime(); }
DistributedFuture extends AbstractFuture<V> { public boolean setException(Throwable e) { return super.setException(e); } DistributedFuture(IExecutorTopologyService<GROUP> topologyService, GROUP group, UUID taskId); @Override boolean cancel(boolean mayInterruptIfRunning); boolean setCancelled(boolean mayInterruptIfRunning); boolean setException(Throwable e); boolean set(V value); long getCreatedTime();  }