如何定义命名通道消费者模块部署属性？

Question

给定以下流定义："http | json-to-tuple > queue:job:process-data"。我如何解决 "process-data" 部署属性（例如计数和消费者并发性 - 我正在使用 rabbitmq）？

我试过 module.*.count=0，但过程数据模块总是部署在单个容器中（我有一个包含 2 个容器的集群）。此外，当尝试使用 module.process-data.count=0 spring-xd 时说唯一可用的模块是 http 和 json-to-tuple.

我正在使用 spring-xd 1.2.1.

谢谢

Answer 1

process-data 不是模块，它只是 json-to-tuple.

的命名输出通道

这是一种将两个流连接在一起的机制；

foo | bar | baz

与

相同

foo | bar > xyz

xyz > baz

它为单个流中的第二个 | 命名 xyz。