fix(consumers/state): wrap listeners with semaphore

fix(consumers/state): wrap listeners with semaphore #335