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,
Envelope message)
|
protected InvocationResult |
invokeOnClusterFirstResponse(Envelope message,
InvocationMetaData metaData,
Address target)
|
protected InvocationResult |
invokeOnClusterOneWay(Envelope message,
InvocationInfo invInfo,
Address target)
|
protected InvocationResult |
invokeOnClusterRequestReply(Envelope message,
InvocationMetaData metaData,
Address target)
|
protected InvocationResult |
invokeOnClusterWithAggregation(Envelope envelope,
InvocationMetaData metaData,
Address target)
|
protected InvocationResult |
invokeOnPeers(InvocationInfo invInfo,
Envelope envelope)
|
protected void |
sendInvocation(InvocationInfo invInfo,
Envelope envelope,
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,
Envelope envelope)
sendInvocation
protected void sendInvocation(InvocationInfo invInfo,
Envelope envelope,
Peer[] targetPeers)
throws MessageExchangeException
- Throws:
MessageExchangeException
combineResults
protected InvocationResult combineResults(InvocationMetaData metaData,
java.util.Collection messages)
invokeOnCluster
protected InvocationResult invokeOnCluster(InvocationInfo invInfo,
Envelope message)
invokeOnClusterRequestReply
protected InvocationResult invokeOnClusterRequestReply(Envelope message,
InvocationMetaData metaData,
Address target)
invokeOnClusterFirstResponse
protected InvocationResult invokeOnClusterFirstResponse(Envelope message,
InvocationMetaData metaData,
Address target)
invokeOnClusterWithAggregation
protected InvocationResult invokeOnClusterWithAggregation(Envelope envelope,
InvocationMetaData metaData,
Address target)
invokeOnClusterOneWay
protected InvocationResult invokeOnClusterOneWay(Envelope message,
InvocationInfo invInfo,
Address target)
Copyright © 2011. All Rights Reserved.