jp.go.nict.langrid.servicecontainer.handler
クラス 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.

作成者:

Takao Nakaguchi

コンストラクタの概要

RIProcessor()

メソッドの概要

static long	appendInvocationHeaders(long iid, String invocationName, Map<String,Object> mimeHeaders, SoapHeaders soapHeaders)
static void	finish(MimeHeaders resMimeHeaders, SOAPHeader resSoapHeader) 処理を終了する。
static void	fork(RIProcessorContext orgContext)
static RIProcessorContext	getCurrentProcessorContext()
static ServiceContext	getCurrentServiceContext() 現在のサービスコンテキストを取得する。
static void	initEndpointRewriters(EndpointRewriter[] rewriters)
static RIProcessorContext	join() forkした処理を終了し、スタックに積んだプロセスIDをポップして返す。
static void	mergeContext(RIProcessorContext context)
static long	newInvocationId() allocate the new invocation id.
static void	processInvocationResponseHeaders(long invocationId, String invocationName, long deltaTime, MimeHeaders mimeHeaders, Iterator<SOAPHeaderElement> soapHeaders, SOAPFault soapFault)
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) 処理を開始する。

クラス java.lang.Object から継承されたメソッド

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

コンストラクタの詳細

RIProcessor

public RIProcessor()

メソッドの詳細

getCurrentServiceContext

public static ServiceContext getCurrentServiceContext()

現在のサービスコンテキストを取得する。startに渡されたサービスコンテキストが返される。 まだ一度もstartが呼び出されていない場合、nullが返される。

getCurrentProcessorContext

public static RIProcessorContext getCurrentProcessorContext()

start

public static RIProcessorContext start(ServiceContext context)

処理を開始する。プロセスIDを発行し、スレッド毎に持っているスタックにプッシュする。

パラメータ:

context - サービスコンテキスト

start

public static RIProcessorContext start(ServiceContext context,
                                       SoapHeaderElementFactory soapHeaderElementFactory)

処理を開始する。プロセスIDを発行し、スレッド毎に持っているスタックにプッシュする。

パラメータ:

context - サービスコンテキスト

soapHeaderElementFactory - SOAPHeaderElementのファクトリ

finish

public static void finish(MimeHeaders resMimeHeaders,
                          SOAPHeader resSoapHeader)

処理を終了する。スタックに積んだプロセスIDをポップする。

fork

public static void fork(RIProcessorContext orgContext)

join

public static RIProcessorContext join()

forkした処理を終了し、スタックに積んだプロセスIDをポップして返す。

mergeContext

public static void mergeContext(RIProcessorContext context)

newInvocationId

public static long newInvocationId()

allocate the new invocation id.

戻り値:

invocation id

initEndpointRewriters

public static void initEndpointRewriters(EndpointRewriter[] rewriters)

rewriteEndpoint

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

エンドポイント(接続先)の取得

例外:

ServiceNotActiveException

rewriteEndpoint

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

エンドポイント(接続先)の取得

例外:

ServiceNotActiveException

appendInvocationHeaders

public static long appendInvocationHeaders(long iid,
                                           String invocationName,
                                           Map<String,Object> mimeHeaders,
                                           SoapHeaders soapHeaders)

processInvocationResponseHeaders

public static void processInvocationResponseHeaders(long invocationId,
                                                    String invocationName,
                                                    long deltaTime,
                                                    MimeHeaders mimeHeaders,
                                                    Iterator<SOAPHeaderElement> soapHeaders,
                                                    SOAPFault soapFault)