我正在寻找一种干净的方法来实现一个java事件系统，该系统可以挂接到hadoopv2中。我知道有一个通知的网址，我已经用了过去。我要做的是挂接到jobstatus并将事件发布到队列服务，以便将事件传播到客户端。我尝试扩展job并使用反射将状态分配给我的自定义jobstatus类，但这不起作用。我还粗略地查看了yarn的事件系统，添加了一个钩子，它允许我监听yarn事件并传播这些事件。我真的需要一个关于如何完成这类任务的Maven意见。我想得到日志消息，状态变化事件实时传递到一个网络客户端。
谢谢你的帮助。