После обработки потока (применение фильтра и т. Д.) Может ли каждый из оставшихся элементов в обработанном потоке инициировать события напрямую, а не записываться в приемник?
У меня есть несколько устройств хранениясообщать о состоянии на сервер Hazelcast Jet Stream. Сервер выполняет некоторую фильтрацию потока и сохраняет только те устройства, которые действительно находятся в плохом состоянии. Я хочу, чтобы эти устройства напрямую вызывали некоторые события обслуживания вместо записи в приемник (например, IMAP). В настоящее время я собираюсь передать поток в IMAP и зарегистрировать слушателей на карте. Однако я не уверен, является ли это наилучшей практикой для моего варианта использования. В основном у меня есть две проблемы:
- Мне не обязательно хранить эти устройства. Все, что мне нужно, это сообщить какой-то другой службе, что устройство должно обслуживаться.
- Док говорит, что в слушателя не должна быть включена тяжелая логика. Что мне делать, если задача, вызванная событием, является всеобъемлющей?