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

protected	RegisterDistributedEventContainerTask()
	RegisterDistributedEventContainerTask(String containerName)

Method Summary

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 Detail

RegisterDistributedEventContainerTask

protected RegisterDistributedEventContainerTask()

RegisterDistributedEventContainerTask

public RegisterDistributedEventContainerTask(String containerName)

Method Detail

reduce

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

Specified by:

reduce in interface AsyncResultsReducer<Serializable,Object>

Throws:

Exception