code: public void start() {
          //log.info("Stream start: {}", publishedName);
          checkVideoCodec = true;
          checkAudioCodec = true;
          firstPacketTime = -1;
          latestTimeStamp = -1;
          bytesReceived = 0;
          IConsumerService consumerManager = (IConsumerService) getScope().getContext().getBean(IConsumerService.KEY);
          connMsgOut = consumerManager.getConsumerOutput(this);
          if (connMsgOut != null && connMsgOut.subscribe(this, null)) {
              // technically this would be a 'start' time
              startTime = System.currentTimeMillis();
          } else {
              log.warn("Subscribe failed");
          }
          setState(StreamState.STARTED);
      }
docs: Starts stream, creates pipes, connects