So I have a system where I have groups of messages that need to be accumulated and then processed exclusively. I might get a message for any group at any time. The space of possible groups is quite large, but at any time I expect there will be a reasonable number of groups active.
My plan was:
producer(group, job)
{
}
