Class FindNonExpiredSessionsTask

java.lang.Object

org.openspaces.pu.container.jee.jetty.session.FindNonExpiredSessionsTask

All Implemented Interfaces:

AsyncResultsReducer<HashSet<String>, HashSet<String>>, Externalizable, Serializable, DistributedTask<HashSet<String>, HashSet<String>>, Task<HashSet<String>>

public class FindNonExpiredSessionsTask
extends Object
implements DistributedTask<HashSet<String>, HashSet<String>>, Externalizable

Since:

15.0.0

Author:

Niv Ingberg

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
FindNonExpiredSessionsTask()	Required for @Externalizable
FindNonExpiredSessionsTask(Set<String> candidates, String contextPath, String vhost, long managedExpiry, long unmanagedExpiry)

Method Summary

Modifier and Type	Method	Description
HashSet<String>	execute()	Computes a result, or throws an exception if unable to do so.
void	readExternal(ObjectInput in)
HashSet<String>	reduce(List<AsyncResult<HashSet<String>>> asyncResults)
void	writeExternal(ObjectOutput out)

Methods inherited from class Object

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

Constructor Details

FindNonExpiredSessionsTask

public FindNonExpiredSessionsTask()

Required for @Externalizable

FindNonExpiredSessionsTask

public FindNonExpiredSessionsTask(Set<String> candidates,
 String contextPath,
 String vhost,
 long managedExpiry,
 long unmanagedExpiry)

Method Details

execute

public HashSet<String> execute()
                        throws Exception

Description copied from interface: Task

Computes a result, or throws an exception if unable to do so.

Specified by:

execute in interface Task<HashSet<String>>

Returns:

computed result

Throws:

Exception - if unable to compute a result

reduce

public HashSet<String> reduce(List<AsyncResult<HashSet<String>>> asyncResults)
                       throws Exception

Specified by:

reduce in interface AsyncResultsReducer<HashSet<String>, HashSet<String>>

Throws:

Exception

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException