Package org.openspaces.events.support

Class RegisterEventContainerTask

java.lang.Object

org.openspaces.events.support.RegisterEventContainerTask

All Implemented Interfaces:

Serializable, AutowireTaskMarker, ProcessObjectsProvider, Task<Serializable>

Direct Known Subclasses:

RegisterDistributedEventContainerTask

public class RegisterEventContainerTask
extends Object
implements Task<Serializable>, ProcessObjectsProvider, AutowireTaskMarker

A task that registers a dynamically added event container (using Polling or Notify.

Author:

kimchy

See Also:

• Serialized Form

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RegisterEventContainerTask()
	RegisterEventContainerTask(Object eventContainer)

Method Summary

Modifier and Type	Method	Description
Serializable	execute()	Computes a result, or throws an exception if unable to do so.
Object[]	getObjectsToProcess()	Returns an array of objects that needs processing on the space node side.

Methods inherited from class java.lang.Object

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

Constructor Details

RegisterEventContainerTask

protected RegisterEventContainerTask()

RegisterEventContainerTask

public RegisterEventContainerTask(Object eventContainer)

Method Details

getObjectsToProcess

public Object[] getObjectsToProcess()

Description copied from interface: ProcessObjectsProvider

Returns an array of objects that needs processing on the space node side. Processing an objects allows to inject resources defined within the processing unit.

Specified by:

getObjectsToProcess in interface ProcessObjectsProvider

execute

public Serializable 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<Serializable>

Returns:

computed result

Throws:

Exception - if unable to compute a result