Fixed issue that if a runnable is retrieved from the awaiting queue
before it registers it's requestId that it would throw a NPE.  This
should only happen if there is a task that is cancelled for some reason
else the consumer found responses should match the queue size.