Now supports multiple products in stream and no queuing