Hazelcast 喷射流可以直接触发事件吗?

Can Hazelcast jet stream directly trigger events?

流被处理后(应用过滤器等),处理过的流中的每个剩余项目是否可以直接触发事件而不是写入接收器?

我有一堆设备不断向 hazelcast 喷射流服务器报告状态。服务器对流进行一些过滤,只保留状态不佳的设备。我希望这些设备直接触发一些维护事件,而不是写入接收器(例如 IMAP)。目前,我正在做的是将流下沉到 IMAP 并在地图上注册监听器。但是,我不确定这是否是我用例的最佳实践。我主要有两个顾虑:

  1. 我不一定需要存储这些设备。我只需要告诉其他服务该设备需要维护。
  2. Doc 说不应在侦听器中放入繁重的逻辑。事件触发的任务比较全面怎么办?

看来您需要的是自定义接收器,请参阅有关该主题的 our Reference Manual section。在 receiveFn 中,您可以通知有关该设备的其他服务。