Streams 190

Creates a throughput queue that allow JMX monitoring of the queues inside of local stream builder.
This looks like the same logic as poll.  Could this be abstracted to a single method?