org.alfresco.jlan.server.filesys.cache.hazelcast

Class RemoteCacheTask<T>

java.lang.Object

org.alfresco.jlan.server.filesys.cache.hazelcast.RemoteCacheTask<T>

All Implemented Interfaces:

com.hazelcast.core.HazelcastInstanceAware, Serializable, Callable<T>

public abstract class RemoteCacheTask<T>
extends Object
implements Callable<T>, com.hazelcast.core.HazelcastInstanceAware, Serializable

Remote Cache Task Class

Base class for remote cache tasks.

Author:

gkspencer

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static int	TaskDebug
static int	TaskTiming

Constructor Summary

Constructors

Constructor and Description
RemoteCacheTask() Default constructor
RemoteCacheTask(String mapName, String key, boolean debug, boolean timingDebug) Class constructor
RemoteCacheTask(String mapName, String key, int options) Class constructor

Method Summary

Methods

Modifier and Type	Method and Description
T	call() Run the remote task
com.hazelcast.core.HazelcastInstance	getHazelcastInstance() Get the Hazelcast instance
String	getKey() Return the file state key
String	getMapName() Return the clustered map name
String	getTaskName() Get the task name
boolean	hasDebug() Check if debug output is enabled for this remote task
boolean	hasOption(int option) Check if the specifed task option is enabled
boolean	hasTimingDebug() Check if the timing debug output is enabled for this remote task
protected abstract T	runRemoteTask(com.hazelcast.core.IMap<String,ClusterFileState> stateCache, String key) Run a remote task
void	setHazelcastInstance(com.hazelcast.core.HazelcastInstance hcInstance) Set the Hazelcast instance

Methods inherited from class java.lang.Object

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

Field Detail

TaskDebug

public static final int TaskDebug

See Also:

Constant Field Values

TaskTiming

public static final int TaskTiming

See Also:

Constant Field Values

Constructor Detail

RemoteCacheTask

public RemoteCacheTask()

Default constructor

RemoteCacheTask

public RemoteCacheTask(String mapName,
               String key,
               int options)

Class constructor

Parameters:

mapName - String

key - String

options - int

RemoteCacheTask

public RemoteCacheTask(String mapName,
               String key,
               boolean debug,
               boolean timingDebug)

Class constructor

Parameters:

mapName - String

key - String

debug - boolean

timingDebug - boolean

Method Detail

getHazelcastInstance

public com.hazelcast.core.HazelcastInstance getHazelcastInstance()

Get the Hazelcast instance

Returns:

HazelcastInstance

setHazelcastInstance

public void setHazelcastInstance(com.hazelcast.core.HazelcastInstance hcInstance)

Set the Hazelcast instance

Specified by:

setHazelcastInstance in interface com.hazelcast.core.HazelcastInstanceAware

Parameters:

hcInstance - HazelcastInstance

getMapName

public final String getMapName()

Return the clustered map name

Returns:

String

getKey

public final String getKey()

Return the file state key

Returns:

String

hasOption

public final boolean hasOption(int option)

Check if the specifed task option is enabled

Parameters:

option - int

Returns:

boolean

hasDebug

public final boolean hasDebug()

Check if debug output is enabled for this remote task

Returns:

boolean

hasTimingDebug

public final boolean hasTimingDebug()

Check if the timing debug output is enabled for this remote task

Returns:

boolean

getTaskName

public final String getTaskName()

Get the task name

Returns:

String

call

public T call()
       throws Exception

Run the remote task

Specified by:

call in interface Callable<T>

Throws:

Exception

runRemoteTask

protected abstract T runRemoteTask(com.hazelcast.core.IMap<String,ClusterFileState> stateCache,
              String key)
                            throws Exception

Run a remote task

Parameters:

stateCache - IMap

key - String

Returns:

T

Throws:

Exception