Diego Lovison created ISPN-9686:
-----------------------------------
Summary: Simplified clustered executor single node submission
Key: ISPN-9686
URL:
https://issues.jboss.org/browse/ISPN-9686
Project: Infinispan
Issue Type: Enhancement
Reporter: Diego Lovison
When working with *DistributedExecutorService* I can do the following
{code:java}
DistributedTask<Boolean> distributedTask = taskBuilder.build();
Future<Boolean> future = des.submit(distributedTask);
Boolean r = future.get();
{code}
But *DistributedExecutorService* is deprecated and we should use ClusterExecutor
As a developer, I would like to execute a function in another node and get the result.
I am expecting something like:
{code:java}
CompletableFuture<Boolean> future = master.executor().singleNodeSubmission(address,
task);
Boolean r = future.get();
{code}
Today, I need the following code to achieve the same result
{code:java}
class MutableString {
String value;
}
MutableString mString = new MutableString();
SerializableFunction<EmbeddedCacheManager, String> callable = (cm) -> {
return "foo";
};
TriConsumer<Address, String, Throwable> triConsumer = (a, v, t) -> {
mString.value = v;
};
master.executor().singleNodeSubmission().filterTargets(a ->
a.equals(address)).submitConsumer(callable, triConsumer).get();
{code}
--
This message was sent by Atlassian Jira
(v7.12.1#712002)