How To Write To All Partitions

edit

Hi Shay. I need to activate the UtilTimerStack in all partitions for profiling purposes, so I create a notify container. I´m sending a command object for that. How can I use the executors in my case, I only need to execute the following line in all partitions: UtilTimerStack.setActive(...);.

Thanks.

So the right way to do this is via executors.
See the distributed task docs.
Shay

I did some reviews of the Executor Component.

I need to implement in the client side something like:

AsyncFuture<string> future = gigaSpace.execute(new TimerTask());

What gigaSpace is refering to?, How can I register the Executor in the pu.xml, it´s necessary to do it?

Thanks

gigaSpace is the org.openspaces.core.GigaSpace Interface

See:

http://www.gigaspaces.com/docs/JavaDocOS6.6/org/openspaces/core/GigaSpace.html

You should use DistributedTask :

public class MyDistTask implements DistributedTask<Integer, Long> {

public Integer execute() throws Exception {

return 1;

}

public Long reduce(List<AsyncResult<Integer>> results)

throws Exception {

long sum = 0;

for (AsyncResult result : results) {

if (result.getException() != null) {

throw result.getException();

}

sum += result.getResult();

}

return sum;

}

}

AsyncFuture<Integer> future = gigaSpace.execute(new MyDistTask());

int result = future.get();

Shay

I understand it. I can use any GigaSpace implementation I choose?. How can I register the Executor in the GigaSpace, maybe using th pu.xml like a sync-remoting registration?

Thanks