271.7. 使用 InOut Message Exchange Pattern

Camel 2.8+

虽然 FIX 协议是事件驱动的和异步,但有特定的消息对代表请求的消息交换。要使用 InOut Exchange 模式,应有一个请求消息,并向请求显示单一回复消息。示例包括 OrderStatusRequest message 和 UserRequest。

271.7.1. 为消费者实施 InOut Exchanges

将"exchangePattern=InOut"添加到 QuickFIX/J enpoint URI 中。以下示例中的 MessageOrderStatusService 是一个具有同步服务方法的 bean。该方法返回对请求的响应(本例中为执行端口),然后发回到 requestor 会话。

    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());