add queue to streams

[josedonizetti]

each stream should support a queue, with configurable size to take the pressure of the pipeline and avoid blocking, once this is implemented we should change the pipeline to drop an event if the stream is blocked