GigaSpaces XAP 8.0 API

org.openspaces.events.support
Class RegisterDistributedEventContainerTask

java.lang.Object
  extended by org.openspaces.events.support.RegisterEventContainerTask
      extended by 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

GigaSpaces XAP 8.0 API

Copyright © GigaSpaces.