PartitionLockQueue.poll() is allowed to call checkQueueState(). I have no idea how this was working before...