Designing Custom Multithreading Frameworks in J2EE Containers w/ monitoring

[Jinesh Shah]

Hi:
We are planning to implement a Custom Multithreading Framework in J2EE Containers to meet processing SLA. We want to:
1. Split a job into multiple messages
2. Multiple MDBs process these messages in parallel and asyncronously
3. Once all MDBs have completed processing all the messages associated with that particular job, marks the job as successful and invoke another function to act on data generated by the MDBs in step# 2.
4. Also monitor the MDBs for some kind of timeout, so if a message from a particular job is not processed in some predetermined time interval fail the job.

Requirements 1 and 2 can be handled by designing a framework similar to the one described here:
http://java.sys-con.com/read/83057_1.htm

Can someone please suggest me how to implement requirement# 3 and 4 in a J2EE container?

Thanks in advance for you help.

PS: I am a newbie in the J2EE world, so your helpful suggestions will be appreciated.