271.11. 路由示例
QuickFIX/J 组件源代码中包含了一些示例(测试子目录)。这些示例之一实施三大交易超值模拟。这个示例定义了一个使用 URI 方案 "trade-executor" 的应用程序组件。
以下路由接收了交易执行器会话的信息,并将应用程序消息传递给 trade executor 组件。
from("quickfix:examples/inprocess.cfg?sessionID=FIX.4.2:MARKET->TRADER"). filter(header(QuickfixjEndpoint.EVENT_CATEGORY_KEY).isEqualTo(QuickfixjEventCategory.AppMessageReceived)). to("trade-executor:market");
trade executor 组件会生成信息,它们被路由到交易会话。会话 ID 必须在 FIX 消息本身中设置,因为端点 URI 中没有指定会话 ID。
from("trade-executor:market").to("quickfix:examples/inprocess.cfg");
交易会话会消耗来自市场的执行报告信息并对其进行处理。
from("quickfix:examples/inprocess.cfg?sessionID=FIX.4.2:TRADER->MARKET"). filter(header(QuickfixjEndpoint.MESSAGE_TYPE_KEY).isEqualTo(MsgType.EXECUTION_REPORT)). bean(new MyTradeExecutionProcessor());