Hazelcast, фильтрующий тематические сообщения через MessageListener с предикатом - PullRequest
0 голосов
/ 04 октября 2019

Когда я регистрирую MessageListener на ITopic, могу ли я где-то указать предикат? Я вижу некоторую поддержку Предикатов в EventService SPI, но это не похоже на публичную публикацию в ITopic, как это делают соответствующие методы в IMap. Есть ли безопасный способ обойти это с помощью последней версии Hazelcast?

EventService имеет прототип метода «EventRegistration registerListener (String serviceName, String topic, EventFilter filter, Object listener)», поэтому он выглядит так, как будто поддерживается в теории.

Бонус 1. Применяются ли предикаты к узлу, который генерирует события, для эффективности? Бонус 2: Если умирает узел с зарегистрированными слушателями, Hazelcast автоматически исключит регистрации слушателей, чтобы генерирующие узлы больше не отправляли сообщения на сбойные узлы через свои регистрации?

...