[infinispan-issues] [JBoss JIRA] (ISPN-1974) Add <T> Future<T> submit(Address target, Callable<T> task) at least to DefaultExecutorService

[Thomas Fromm (JIRA)]

Thomas Fromm created ISPN-1974:
----------------------------------

             Summary: Add <T> Future<T> submit(Address target, Callable<T> task) at least to DefaultExecutorService
                 Key: ISPN-1974
                 URL: https://issues.jboss.org/browse/ISPN-1974
             Project: Infinispan
          Issue Type: Enhancement
          Components: Core API
    Affects Versions: 5.1.3.FINAL
            Reporter: Thomas Fromm
            Assignee: Manik Surtani


To easy execute tasks on specific nodes I'd like to have an additional method at DefaultExecutorService:

{code}
       public <T> Future<T> submit(Address target, Callable<T> task){
            if (task == null) throw new NullPointerException();
            if (target == null) throw new NullPointerException();
            List<Address> members = rpc.getTransport().getMembers();
            if(!members.contains(target)){
                throw new IllegalArgumentException("Unknown node "+target.toString());
            }
            Address me = rpc.getAddress();
            DistributedExecuteCommand<T> c = null;
            if(target.equals(me)){
                c = factory.buildDistributedExecuteCommand(clone(task), me, null);
            } else {
                c = factory.buildDistributedExecuteCommand(task, me, null);
            }
            DistributedRunnableFuture<T> f = new DistributedRunnableFuture<T>(c);
            executeFuture(target, f);
            return f;
        }
{code}

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.jboss.org/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira