107.7. 使用 Request Reply
SEDA 组件支持使用 Request Reply,调用者将等待 Async 路由完成。例如:
from("mina:tcp://0.0.0.0:9876?textline=true&sync=true").to("seda:input"); from("seda:input").to("bean:processInput").to("bean:createResponse");
在上面的路由中,我们在端口 9876 上有一个 TCP 侦听器,它接受传入的请求。请求被路由到 seda:input
队列。因为它是一个 Request Reply 消息,我们等待响应。当 seda:input
队列上的消费者完成后,它会将响应复制到原始消息响应。