jp.go.nict.langrid.servicecontainer.handler

Class RIProcessor

java.lang.Object

jp.go.nict.langrid.servicecontainer.handler.RIProcessor

public class RIProcessor
extends Object

The processor for receiving and replying request and invocating component services.

Author:

Takao Nakaguchi

Constructor Summary

Constructors

Constructor and Description
RIProcessor()

Method Summary

Methods

Modifier and Type	Method and Description
static long	appendInvocationHeaders(long iid, String invocationName, Map<String,Object> mimeHeaders, Collection<jp.go.nict.langrid.commons.rpc.RpcHeader> rpcHeaders)
static ServiceLoader	createServiceLoader()
static void	finish()
static void	finish(MimeHeaders resMimeHeaders, Collection<jp.go.nict.langrid.commons.rpc.RpcHeader> resRpcHeaders)
static void	fork(RIProcessorContext orgContext)
static RIProcessorContext	getCurrentProcessorContext()
static ServiceContext	getCurrentServiceContext()
static void	initEndpointRewriters(EndpointRewriter[] rewriters)
static RIProcessorContext	join()
static void	mergeContext(RIProcessorContext context)
static long	newInvocationId() allocate the new invocation id.
static void	processInvocationResponseHeaders(long invocationId, String invocationName, long deltaTime, MimeHeaders mimeHeaders, Iterable<jp.go.nict.langrid.commons.rpc.RpcHeader> rpcHeaders, jp.go.nict.langrid.commons.rpc.RpcFault rpcFault)
static Endpoint	rewriteEndpoint(long iid, String invocationName, EndpointRewriter[] rewriters)
static Endpoint	rewriteEndpoint(long iid, String invocationName, EndpointRewriter[] rewriters, Endpoint original)
static RIProcessorContext	start(ServiceContext context)
static RIProcessorContext	start(ServiceContext context, SoapHeaderElementFactory soapHeaderElementFactory)

Methods inherited from class java.lang.Object

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

Constructor Detail

RIProcessor

public RIProcessor()

Method Detail

getCurrentServiceContext

public static ServiceContext getCurrentServiceContext()

getCurrentProcessorContext

public static RIProcessorContext getCurrentProcessorContext()

createServiceLoader

public static ServiceLoader createServiceLoader()

start

public static RIProcessorContext start(ServiceContext context)

start

public static RIProcessorContext start(ServiceContext context,
                       SoapHeaderElementFactory soapHeaderElementFactory)

finish

public static void finish()

finish

public static void finish(MimeHeaders resMimeHeaders,
          Collection<jp.go.nict.langrid.commons.rpc.RpcHeader> resRpcHeaders)

fork

public static void fork(RIProcessorContext orgContext)

join

public static RIProcessorContext join()

mergeContext

public static void mergeContext(RIProcessorContext context)

newInvocationId

public static long newInvocationId()

allocate the new invocation id.

Returns:

invocation id

initEndpointRewriters

public static void initEndpointRewriters(EndpointRewriter[] rewriters)

rewriteEndpoint

public static Endpoint rewriteEndpoint(long iid,
                       String invocationName,
                       EndpointRewriter[] rewriters)

rewriteEndpoint

public static Endpoint rewriteEndpoint(long iid,
                       String invocationName,
                       EndpointRewriter[] rewriters,
                       Endpoint original)

appendInvocationHeaders

public static long appendInvocationHeaders(long iid,
                           String invocationName,
                           Map<String,Object> mimeHeaders,
                           Collection<jp.go.nict.langrid.commons.rpc.RpcHeader> rpcHeaders)

processInvocationResponseHeaders

public static void processInvocationResponseHeaders(long invocationId,
                                    String invocationName,
                                    long deltaTime,
                                    MimeHeaders mimeHeaders,
                                    Iterable<jp.go.nict.langrid.commons.rpc.RpcHeader> rpcHeaders,
                                    jp.go.nict.langrid.commons.rpc.RpcFault rpcFault)