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 ) ; }
Starts stream creates pipes connects