Goal: I want to create an internal event listener / bridge that can take the events from hadoop's event Dispatcher and forward those to an activeMQ jms system. This would allow me to cleanly notify clients of their job status.
Investigations: I have dug into the Dispatcher (in MRAppMaster) and it looks like it dispatches the events that I wish to register and listen for. I have looked at the JobHistoryHandler and have a good idea of how the events are processed and handled. I am looking for some advice on where to register hooks and or can I add a service that will register for events with the Dispatcher. Ideally this would like this to work for a local job as well as a Yarn submitted job but if it only works with Yarn this would be fine for my cases. Any advice would be greatly appreciated on where to add these hooks or if they already exist. Sorry if this is the wrong forum. Thanks, Chris Hinshaw
