jp.go.nict.langrid.servicecontainer.executor.protobufrpc

Class AbstractPbServiceExecutor

java.lang.Object

jp.go.nict.langrid.servicecontainer.service.component.AbstractServiceExecutor

jp.go.nict.langrid.servicecontainer.executor.protobufrpc.AbstractPbServiceExecutor

Direct Known Subclasses:

CachingDynamicPbServiceExecutor, DynamicPbServiceExecutor

public abstract class AbstractPbServiceExecutor
extends AbstractServiceExecutor

Author:

Takao Nakaguchi

Constructor Summary

Constructors

Constructor and Description
AbstractPbServiceExecutor(String invocationName)
AbstractPbServiceExecutor(String invocationName, long invocationId, Endpoint endpoint)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	postprocessPb(long iid, long deltaTime, DefaultRpcController controller, URLRpcChannel channel, List<CommonProtos.Header> responseHeaders, CommonProtos.Fault fault)
protected jp.go.nict.langrid.commons.util.Pair<URLRpcChannel,Long>	preprocessPb(List<jp.go.nict.langrid.commons.rpc.RpcHeader> rpcHeaders)

Methods inherited from class jp.go.nict.langrid.servicecontainer.service.component.AbstractServiceExecutor

getInvocationName, postprocess, preprocess

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractPbServiceExecutor

public AbstractPbServiceExecutor(String invocationName)

AbstractPbServiceExecutor

public AbstractPbServiceExecutor(String invocationName,
                         long invocationId,
                         Endpoint endpoint)

Method Detail

preprocessPb

protected jp.go.nict.langrid.commons.util.Pair<URLRpcChannel,Long> preprocessPb(List<jp.go.nict.langrid.commons.rpc.RpcHeader> rpcHeaders)

postprocessPb

protected void postprocessPb(long iid,
                 long deltaTime,
                 DefaultRpcController controller,
                 URLRpcChannel channel,
                 List<CommonProtos.Header> responseHeaders,
                 CommonProtos.Fault fault)