Skip navigation links
com.tangosol.net
Class WrapperInvocationService
java.lang.Object
com.tangosol.net.WrapperService
com.tangosol.net.WrapperInvocationService
- All Implemented Interfaces:
- ClassLoaderAware, InvocationService, Controllable, Service
-
public class WrapperInvocationService
- extends WrapperService
- implements InvocationService
InvocationService implementation that delegates to a wrapped InvocationService instance.
- Author:
- jh 2010.03.17
Methods inherited from class com.tangosol.net.WrapperService |
addMemberListener, addServiceListener, configure, getCluster, getContextClassLoader, getInfo, getSerializer, getService, getUserContext, isRunning, removeMemberListener, removeServiceListener, setContextClassLoader, setUserContext, shutdown, start, stop |
WrapperInvocationService
public WrapperInvocationService(InvocationService service)
- Create a new WrapperInvocationService that delegates to the given InvocationService instance.
- Parameters:
service
- the InvocationService to wrap
execute
public void execute(Invocable task,
java.util.Set setMembers,
InvocationObserver observer)
- Asynchronously invoke the specified task on each of the specified members. This method may return before the task is executed, or before it finishes executing, or after it finishes executing, or any of the above; however, it is expected that aggressive implementations will attempt to return as quickly as possible.
-
- Specified by:
execute
in interface InvocationService
-
- Parameters:
task
- the Invocable object to distribute to the specified members in order to be invoked on those members
setMembers
- (optional) a set of cluster members to which the Invocable object will be distributed; if null, the Invocable object will be distributed to all cluster members that are running this service
observer
- (optional) the InvocationObserver object that will receive notifications related to the Invocable object
query
public java.util.Map query(Invocable task,
java.util.Set setMembers)
- Synchronously invoke the specified task on each of the specified members. This method will not return until the specified members have completed their processing, failed in their processing, or died trying.
Members that are specified but are not currently running the InvocationService will not invoke the specified Invocable object. Members that leave (gracefully or otherwise) before the invocation completes will not register a result, and the amount of processing that completed is indeterminate. Members that encounter an exception during invocation will not be retried and no result is returned. Specifically, the result for a given member will not be present under the following conditions:
- if the member did not exist
- if the member was not running the service at the time that the query method was invoked
- if the member left (via the shutdown or stop methods, or unexpectedly) before responding
- if the member encountered an exception while processing and had not registered a non-null result
- if the member completed successfully but registered no result
- if the member completed successfully but explicitly registered a result of null
-
- Specified by:
query
in interface InvocationService
-
- Parameters:
task
- the Invocable object to distribute to the specified members in order to be invoked on those members
setMembers
- (optional) a set of cluster members to which the Invocable object will be distributed; if null, the Invocable object will be distributed to all cluster members that are running this service
- Returns:
- a Map of result objects keyed by Member object
toString
public java.lang.String toString()
-
- Overrides:
toString
in class WrapperService
getInvocationService
public InvocationService getInvocationService()
- Return the wrapped InvocationService.
-
- Returns:
- the wrapped InvocationService
Skip navigation links
Copyright © 2000, 2011, Oracle and/or its affiliates. All rights reserved.