org.infinispan.server.core.transport

Class ConnectionAdderTask

java.lang.Object

org.infinispan.server.core.transport.ConnectionAdderTask

All Implemented Interfaces:

Serializable, Callable<Integer>, DistributedCallable<Object,Object,Integer>

public class ConnectionAdderTask
extends Object
implements DistributedCallable<Object,Object,Integer>, scala.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ConnectionAdderTask(String serverName)

Method Summary

Methods

Modifier and Type	Method and Description
Cache<Object,Object>	cache()
Integer	call()
void	setEnvironment(Cache<Object,Object> cache, Set<Object> inputKeys) Invoked by execution environment after DistributedCallable has been migrated for execution to a specific Infinispan node.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectionAdderTask

public ConnectionAdderTask(String serverName)

Method Detail

cache

public Cache<Object,Object> cache()

call

public Integer call()

Specified by:

call in interface Callable<Integer>

setEnvironment

public void setEnvironment(Cache<Object,Object> cache,
                  Set<Object> inputKeys)

Description copied from interface: DistributedCallable

Invoked by execution environment after DistributedCallable has been migrated for execution to a specific Infinispan node.

Specified by:

setEnvironment in interface DistributedCallable<Object,Object,Integer>

Parameters:

cache - cache whose keys are used as input data for this DistributedCallable task

inputKeys - keys used as input for this DistributedCallable task