Added a limit on fifo queues to avoid memory exaustion when messages are received faster than handled