Package org.openspaces.events.support

Class RegisterDistributedEventContainerTask

java.lang.Object

org.openspaces.events.support.RegisterEventContainerTask

org.openspaces.events.support.RegisterDistributedEventContainerTask

All Implemented Interfaces:

AsyncResultsReducer<Serializable,Object>, Serializable, AutowireTaskMarker, DistributedTask<Serializable,Object>, ProcessObjectsProvider, Task<Serializable>

public class RegisterDistributedEventContainerTask
extends RegisterEventContainerTask
implements DistributedTask<Serializable,Object>

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

Author:

kimchy

See Also:

• Serialized Form

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RegisterDistributedEventContainerTask()
	RegisterDistributedEventContainerTask(String containerName)

Method Summary

Modifier and Type	Method	Description
Object	reduce(List<AsyncResult<Serializable>> asyncResults)

Methods inherited from class org.openspaces.events.support.RegisterEventContainerTask

execute, getObjectsToProcess

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.openspaces.core.executor.Task

execute

Constructor Details

RegisterDistributedEventContainerTask

protected RegisterDistributedEventContainerTask()

RegisterDistributedEventContainerTask

public RegisterDistributedEventContainerTask(String containerName)

Method Details

reduce

public Object reduce(List<AsyncResult<Serializable>> asyncResults)
              throws Exception

Specified by:

reduce in interface AsyncResultsReducer<Serializable,Object>

Throws:

Exception