This will only work if there is one worker with the given `workerType`. Alternatives, is to implement the scheme I outlined in comment for `Listener`. Or to receive all events for given `workerType` and just test if they have the right `taskId` when you receive them...

All messages carries that task status structure, so the `taskId` is `message.status.taskId`. Anyways, this will fail if multiple workers and tasks a submitted for the same `workerType`, which is to be expected.