我的任务是设置一个运行如下的应用程序：

1） 接收TCP>转换>发送TCP>接收TCP>日志>响应消息>发送TCP响应

接收TCP>转换>发送HTTP>接收HTTP>日志>空

2）
接收TCP>转换>发送TCP>接收TCP>日志>空
接收TCP>转换>发送HTTP>接收HTTP>日志>转换响应消息>发送TCP响应

只有并行进程之一将生成响应，其他进程将在记录后发送到Null通道。 我使用.route（）将其用于每个进程，但是当我尝试使用routeToRecipients时，无法获得返回消息（一种方式）。 当我尝试publishSubscribeChannel时，流程在“接收HTTP / TCP”步骤之后结束，没有消息通过TCP发送回。 我正在使用Executors.newCachedThreadPool（）。 如何获得一个（只有一个）并行通道以将消息返回到原始TCP连接？ 最好的方法是什么？
任何帮助或指针，表示赞赏。