説明

カスタムアダプターがSDPサーバとインプロセスで連携するためには，StreamInprocessUPインタフェースを実装するクラスを作成する必要があります。

StreamInprocessUPインタフェースには，executeメソッドとstopメソッドがあります。

executeメソッドには，カスタムアダプターのmainメソッドに相当するメイン処理を記述します。stopメソッドには，カスタムアダプターの終了処理を記述します。

sdpstartinproコマンドを実行してインプロセス連携カスタムアダプターを起動すると，SDPサーバによってStreamInprocessUPインタフェースを実装したクラスがロードされ，executeメソッドを実行するためのスレッド（カスタムアダプター実行スレッド）が生成されます。executeメソッドはこのスレッドから呼び出されるメソッドです。なお，SDPサーバによってロードされる実装クラス名，およびその実装クラスが格納されたjarファイルのパス名は，プロパティファイルuser_app.＜インプロセス連携カスタムアダプター名＞.propertiesに記述します。プロパティファイルについては，マニュアル「uCosminexus Stream Data Platform - Application Framework システム構築・運用ガイド」を参照してください。

stopメソッドは，sdpstopinproコマンドを実行してインプロセス連携カスタムアダプターを停止するときに，SDPサーバ側のスレッドから呼び出されます。

メソッド

StreamInprocessUPインタフェースのメソッド一覧を次の表に示します。

戻り値	メソッド名	機能
void	execute(SDPConnector con)	カスタムアダプターのメイン処理を記述します。 このメソッドは，sdpstartinproコマンド実行時に，SDPサーバが生成したカスタムアダプター実行スレッドによって呼び出されます。
void	stop()	カスタムアダプターの終了処理を記述します。 このメソッドは，sdpstopinproコマンド実行時に，SDPサーバ側のスレッドによって呼び出されます。

注意事項

• StreamInprocessUPインタフェースのexecuteメソッドで起動したユーザースレッドは，stopメソッドの中で必ず停止してください。stopメソッドに停止処理を記述しなかった場合，またはstopメソッドで停止できない無限ループなどの処理がユーザースレッドに含まれる場合，ユーザースレッドが停止されないで残ることがあります。
• StreamInprocessUPインタフェースのexecuteメソッドに無限ループなどの処理を記述した場合，executeメソッド自身の実行スレッドが残ってしまうことがあります。
• カスタムアダプターに任意の引数を渡す場合は，String型の可変長引数を持つコンストラクターを実装してください。リフレクション経由で作成したString型の可変長引数を持つコンストラクターが呼ばれます。その引数として，sdpstartinproコマンドで定義した任意の引数が渡されます。なお，String型の可変長引数を持つコンストラクターを実装していない場合は，デフォルトコンストラクターが呼ばれます（ただし，引数は渡されません）。
• カスタムアダプターに任意の引数を渡さない場合は，String型の可変長引数を持つコンストラクターまたはデフォルトコンストラクターのどちらかを実装してください。どちらも実装している場合は，String型の可変長引数を持つコンストラクターが呼ばれます。
• String型の可変長引数を持つコンストラクターまたはデフォルトコンストラクターのどちらも実装していない場合は，エラーとなり，カスタムアダプターは起動しません。

＜この節の構成＞

execute(SDPConnector con)メソッド

stop()メソッド