Was having some wierd issues with the consumer.. disabled continuations for now (but i don't think that was the issue). added a semaphore to avoid multiple blocking threads (i've got a feeling this might be what fixed it).