Adding a blocking flush method of QueueConsumers
Adding error logging