Слушатели динамических приемников Spring Cloud Stream

Я начинаю использовать SCS, и у меня есть следующий вариант использования:

  1. Пользователь открывает сеанс HTTP
  2. Сервер динамически определяет, для какого раздела создать прослушиватель приемника, на основе атрибутов безопасности пользователя.
  3. Создается Sink/Listener, специфичный для сеанса пользователя и присоединяемый к разделу канала.
  4. Сообщения пересылаются через веб-сокет http клиенту браузера.
  5. Когда пользователь выходит из системы, слушатель на канале должен быть уничтожен.

Чтение справочной документации не показывает, зачем нужна такая динамическая конфигурация и управление жизненным циклом. Любая подсказка о том, как этого добиться?


person Hristo Stoyanov    schedule 22.08.2016    source источник


Ответы (1)


Я также смотрю на это.

Прямо сейчас я могу создавать динамические производители, используя BinderAwareChannelResolver. Но, к сожалению, я ничего не нашел о динамических потребителях.

person Murasame    schedule 14.10.2016