It has a problem with the consumer not printing any output until there are messages in the queue by the time it is started.