Для Spring XD 1.3.1, с использованием транспорта Rabbit MQ, распространяется.
Нужны пояснения о том, как работают ответвители Spring XD для показателей. Мне нужно знать, можно ли использовать один поток несколько раз, чтобы каждое сообщение через основной поток было отправлено на каждый из активных определенных ответвлений.
Сценарий представляет собой поток с источником-кроликом, который обрабатывается перед доставкой в приемник, например mongo. Этот поток переходит в альтернативный приемник. Мы также хотим создать несколько метрик в этом потоке, включая агрегированный счетчик и пару счетчиков значений полей, которые будут хранить метрики для общего количества сообщений и сообщений по типу, просматривая разные поля в исходном сообщении (которые находятся в JSON).
В документации неясно, получает ли каждое нажатие копию сообщения.
При тестировании первое нажатие получает все сообщения, но ни одно из значений поля или совокупных счетчиков, похоже, не получает данные.
