[infinispan-issues] [JBoss JIRA] (ISPN-1513) Enhance distributed executor framework to be more topology aware

Enhance distributed executor framework to be more topology aware ---------------------------------------------------------------- Key: ISPN-1513 URL: https://issues.jboss.org/browse/ISPN-1513 Project: Infinispan Issue Type: Enhancement Components: Distributed Cache Affects Versions: 5.0.1.FINAL Reporter: David B Assignee: Vladimir Blagojevic Priority: Minor Fix For: 5.2.0.FINAL Our environment has 2 local infinispan/jgroups clusters with a jgroups relay cluster to handle geographic failover. Our sites are geographically distant over a WAN. Currently DistributedExecutorService's submitEverywhere() sends Callables to every node in both local clusters. We would rather have additional methods provided to DistributedExecutorService to constrain submission on Callables to the same/local site. Currently I have extended DefaultExecutorService with my own TopologyAwareExecutorService and added a submitSameSite() method using the TopologyAwareAddress.isSameSite(). I did need to patch DistributedRunnableFuture in DefaultExecutorService to mark it protected vs. private. This could be extended to also provide submitSameRack() & submitSameMachine() though currently we don't have a use case for that.