Как определить свойства развертывания потребительского модуля именованного канала?

Question

Учитывая следующее определение потока: «http | json-to-tuple> queue: job: process-data». Как я могу обратиться к свойствам развертывания «данные процесса» (например, подсчет и параллелизм пользователей - я использую rabbitmq)?

Я пробовал модуль. *. 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 ко второму | в одном потоке.