Streams 190

Creates a throughput queue that allow JMX monitoring of the queues inside of local stream builder.
Could this be abstracted to a common method
`
this.elementsAdded.incrementAndGet();
            synchronized (this) {
               if (!this.active) {
                    this.startTime.set(System.currentTimeMillis());
                   this.active = true;
              }           }`