试图构建一个扭曲的应用程序,它将在多个端口上接收消息。端口应该生成Alert
具有tag
属性和trigger
属性的对象。然后应用程序应该检查是否已经存在AlertJob
带有该标签的标签。如果有,则应将其排入队列Alert
,AlertJob
如果没有,则应首先创建新的AlertJob
. 的AlertJob
... 工作是定期检查触发器,如果满足触发器条件,则再次通知主应用程序。这是我的问题:
如何将自定义类(AlertJob
)挂接到扭曲的反应器中,以便它不断验证是否满足任何正在运行的作业的触发条件?