271.7. InOut メッセージエクスチェンジパターンの使用

QuickFIX/J エンドポイント URI に "exchangePattern=InOut" を追加します。以下の例の MessageOrderStatusService は、同期サービスメソッドを持つ Bean です。このメソッドは、リクエストに対するレスポンス (この場合は ExecutionReport) を返し、それがリクエスターセッションに送り返されます。

    from("quickfix:examples/inprocess.cfg?sessionID=FIX.4.2:MARKET->TRADER&exchangePattern=InOut")
        .filter(header(QuickfixjEndpoint.MESSAGE_TYPE_KEY).isEqualTo(MsgType.ORDER_STATUS_REQUEST))
        .bean(new MarketOrderStatusService());

プロデューサーの場合、メッセージの送信は、レスポンスが受信されるかタイムアウトが発生するまでブロックされます。FIX でレスポンスメッセージを相互に関連付ける標準的な方法はありません。したがって、InOut エクスチェンジのタイプごとに相関基準を定義する必要があります。相関条件とタイムアウトは、Exchange プロパティーを使用して指定できます。

相関基準は、MessagePredicate オブジェクトで定義されます。次の例では、トランザクションタイプが STATUS で、注文 ID がリクエストと一致する指定されたセッションからの FIX ExecutionReport を処理します。セッション ID は requestor 用である必要があります。sender および target CompID フィールドは、返信を探すときに逆になります。

exchange.setProperty(QuickfixjProducer.CORRELATION_CRITERIA_KEY,
    new MessagePredicate(new SessionID(sessionID), MsgType.EXECUTION_REPORT)
        .withField(ExecTransType.FIELD, Integer.toString(ExecTransType.STATUS))
        .withField(OrderID.FIELD, request.getString(OrderID.FIELD)));

ソースコードには、コンシューマーとプロデューサーの InOut エクスチェンジを示す RequestReplyExample という例が含まれています。この例では、注文状況リクエストを受け入れる単純な HTTP サーバーエンドポイントを作成します。HTTP リクエストは FIX OrderStatusRequestMessage に変換され、相関基準で拡張されてから、quickfix エンドポイントにルーティングされます。次に、レスポンスは JSON 形式の文字列に変換され、HTTP サーバーエンドポイントに返されて、Web レスポンスとして提供されます。

Spring 設定は、Camel 2.9 以降で変更されました。例は、以下を参照してください。