org.springframework.data.gemfire.function

Class PojoFunctionWrapper

java.lang.Object

org.springframework.data.gemfire.function.PojoFunctionWrapper

All Implemented Interfaces:

Serializable, org.apache.geode.cache.execute.Function, org.apache.geode.lang.Identifiable

public class PojoFunctionWrapper
extends Object
implements org.apache.geode.cache.execute.Function

Invokes a given POJO Method as a (remote) Pivotal GemFire/Apache Geode Function. If the POJO has a constructor that takes a Map, and the Function context is a Region, the Region will be injected. The delegate class name, the method name, and Method arguments are part of the Function invocation, therefore all arguments must be Serializable or an alternate serialization strategy must be used. The delegate Class must be on the class path of the remote cache(s).

Since:

1.2.0

Author:

David Turanski, John Blum

See Also:

Function, Serialized Form

Constructor Summary

Constructors

Constructor and Description
PojoFunctionWrapper(Object target, Method method, String id)

Method Summary

Modifier and Type	Method and Description
void	execute(org.apache.geode.cache.execute.FunctionContext functionContext)
String	getId()
boolean	hasResult()
protected Object	invokeTargetMethod(Object[] args)
boolean	isHA()
boolean	optimizeForWrite()
void	setBatchSize(int batchSize)
void	setHA(boolean HA)
void	setHasResult(boolean hasResult)
void	setOptimizeForWrite(boolean optimizeForWrite)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PojoFunctionWrapper

public PojoFunctionWrapper(Object target,
                           Method method,
                           String id)

Method Detail

setBatchSize

public void setBatchSize(int batchSize)

setHA

public void setHA(boolean HA)

isHA

public boolean isHA()

Specified by:

isHA in interface org.apache.geode.cache.execute.Function

setHasResult

public void setHasResult(boolean hasResult)

hasResult

public boolean hasResult()

Specified by:

hasResult in interface org.apache.geode.cache.execute.Function

getId

public String getId()

Specified by:

getId in interface org.apache.geode.cache.execute.Function

Specified by:

getId in interface org.apache.geode.lang.Identifiable

setOptimizeForWrite

public void setOptimizeForWrite(boolean optimizeForWrite)

optimizeForWrite

public boolean optimizeForWrite()

Specified by:

optimizeForWrite in interface org.apache.geode.cache.execute.Function

execute

public void execute(org.apache.geode.cache.execute.FunctionContext functionContext)

Specified by:

execute in interface org.apache.geode.cache.execute.Function

invokeTargetMethod

protected final Object invokeTargetMethod(Object[] args)