com.pega.pegarules.pub.context

Interface ClusterExecutor

public interface ClusterExecutor

ExecutorService like interface for running distributed jobs

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	COPYRIGHT
static java.lang.String	VERSION

Method Summary

Methods

Modifier and Type	Method and Description
boolean	canExecuteOn(java.util.UUID node) Checks whether it is possible to execute on the given node
<P extends java.io.Serializable,R extends java.io.Serializable> com.google.common.util.concurrent.ListenableFuture<R>	executeOnNode(java.lang.Class<? extends Job<P,R>> jobClass, P jobData, java.util.UUID node) Runs a job on a remote node
<P extends java.io.Serializable,R extends java.io.Serializable> com.google.common.util.concurrent.ListenableFuture<R>	startStopAgentOnNode(P jobData, java.util.UUID node)

Field Detail

COPYRIGHT

static final java.lang.String COPYRIGHT

See Also:

Constant Field Values

VERSION

static final java.lang.String VERSION

Method Detail

canExecuteOn

boolean canExecuteOn(java.util.UUID node)

Checks whether it is possible to execute on the given node

Parameters:

node - unique id

Returns:

true if execution can be performed on the indicated node.

executeOnNode

<P extends java.io.Serializable,R extends java.io.Serializable> com.google.common.util.concurrent.ListenableFuture<R> executeOnNode(java.lang.Class<? extends Job<P,R>> jobClass,
                                                                                                                                  P jobData,
                                                                                                                                  java.util.UUID node)

Runs a job on a remote node

Parameters:

jobClass - class that implements the job

jobData - to be passed to the job during execution

node - on which to execute the job

Returns:

future result

startStopAgentOnNode

<P extends java.io.Serializable,R extends java.io.Serializable> com.google.common.util.concurrent.ListenableFuture<R> startStopAgentOnNode(P jobData,
                                                                                                                                         java.util.UUID node)