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

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 and Description
FindNonExpiredSessionsTask() Required for @Externalizable
FindNonExpiredSessionsTask(Set<String> candidates, String contextPath, String vhost, long managedExpiry, long unmanagedExpiry)

Method Summary

Modifier and Type	Method and 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 java.lang.Object

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

Constructor Detail

FindNonExpiredSessionsTask

public FindNonExpiredSessionsTask()

Required for @Externalizable

FindNonExpiredSessionsTask

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

Method Detail

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