271.11. 路由示例
QuickFIX/J 组件源代码(测试子目录)中包括几个示例。这些示例之一实施了三倍的交易模拟。这个示例定义了一个应用程序组件,它使用 URI 方案 "trade-executor"。
以下路由接收了交易执行器会话的消息,并将应用消息传递给 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");
交易执行器组件会生成回交易会话的消息。会话 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());