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