org.codehaus.wadi.servicespace.basic
Class BasicServiceInvoker
java.lang.Object
org.codehaus.wadi.servicespace.basic.BasicServiceInvoker
- All Implemented Interfaces:
- ServiceInvoker
public class BasicServiceInvoker
- extends java.lang.Object
- implements ServiceInvoker
- Version:
- $Revision: $
Method Summary |
protected InvocationResult |
combineResults(InvocationMetaData metaData,
java.util.Collection messages)
|
InvocationResult |
invoke(InvocationInfo invInfo)
|
protected InvocationResult |
invokeOnCluster(InvocationInfo invInfo,
org.codehaus.wadi.group.Envelope message)
|
protected InvocationResult |
invokeOnClusterFirstResponse(org.codehaus.wadi.group.Envelope message,
InvocationMetaData metaData,
org.codehaus.wadi.group.Address target)
|
protected InvocationResult |
invokeOnClusterOneWay(org.codehaus.wadi.group.Envelope message,
InvocationInfo invInfo,
org.codehaus.wadi.group.Address target)
|
protected InvocationResult |
invokeOnClusterRequestReply(org.codehaus.wadi.group.Envelope message,
InvocationMetaData metaData,
org.codehaus.wadi.group.Address target)
|
protected InvocationResult |
invokeOnClusterWithAggregation(org.codehaus.wadi.group.Envelope envelope,
InvocationMetaData metaData,
org.codehaus.wadi.group.Address target)
|
protected InvocationResult |
invokeOnPeers(InvocationInfo invInfo,
org.codehaus.wadi.group.Envelope envelope)
|
protected void |
sendInvocation(InvocationInfo invInfo,
org.codehaus.wadi.group.Envelope envelope,
org.codehaus.wadi.group.Peer[] targetPeers)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
BasicServiceInvoker
public BasicServiceInvoker(ServiceSpace serviceSpace,
ServiceName targetServiceName)
invoke
public InvocationResult invoke(InvocationInfo invInfo)
- Specified by:
invoke
in interface ServiceInvoker
invokeOnPeers
protected InvocationResult invokeOnPeers(InvocationInfo invInfo,
org.codehaus.wadi.group.Envelope envelope)
sendInvocation
protected void sendInvocation(InvocationInfo invInfo,
org.codehaus.wadi.group.Envelope envelope,
org.codehaus.wadi.group.Peer[] targetPeers)
throws org.codehaus.wadi.group.MessageExchangeException
- Throws:
org.codehaus.wadi.group.MessageExchangeException
combineResults
protected InvocationResult combineResults(InvocationMetaData metaData,
java.util.Collection messages)
invokeOnCluster
protected InvocationResult invokeOnCluster(InvocationInfo invInfo,
org.codehaus.wadi.group.Envelope message)
invokeOnClusterRequestReply
protected InvocationResult invokeOnClusterRequestReply(org.codehaus.wadi.group.Envelope message,
InvocationMetaData metaData,
org.codehaus.wadi.group.Address target)
invokeOnClusterFirstResponse
protected InvocationResult invokeOnClusterFirstResponse(org.codehaus.wadi.group.Envelope message,
InvocationMetaData metaData,
org.codehaus.wadi.group.Address target)
invokeOnClusterWithAggregation
protected InvocationResult invokeOnClusterWithAggregation(org.codehaus.wadi.group.Envelope envelope,
InvocationMetaData metaData,
org.codehaus.wadi.group.Address target)
invokeOnClusterOneWay
protected InvocationResult invokeOnClusterOneWay(org.codehaus.wadi.group.Envelope message,
InvocationInfo invInfo,
org.codehaus.wadi.group.Address target)
Copyright © 2008. All Rights Reserved.