    @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();
    }