private SourceStream createStream(StreamSet streamSet,
                              int priority,
                              Reliability reliability,
                              long sendWindow,
                              boolean restore ) throws SIResourceException

  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.entry(tc, "createStream",
        new Object[]{streamSet, new Integer(priority), reliability, new Long(sendWindow), Boolean.valueOf(restore)});

    SourceStream stream = createStream(streamSet, priority, reliability);

    // We only use the sendWindow for PtoP in which case the SourceStreamManager
    // will be persistent as it perists the sendWindow for each stream
    if( pointTopoint)
    {
      stream.initialiseSendWindow(sendWindow, messageProcessor.getDefinedSendWindow());

      // If this stream is being recreated after a restore although we
      // may have restored a valid targetMEUuid we don't want to send any messages
      // until the link is started and we know both endpoint MEs
      // Note, defect 238709: An MQLinkHandler is deemed not to be a link
      if( restore && destinationHandler.isLink()&& !destinationHandler.isMQLink() )
      {
        // This will stop the stream sending messages
        stream.guessesInStream();
      }

    }

    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(tc, "createStream", stream);
    return stream;
  }
private SourceStream createStream ( StreamSet streamSet , int priority , Reliability reliability , long sendWindow , boolean restore ) throws SIResourceException { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "createStream" , new Object [ ] { streamSet , new Integer ( priority ) , reliability , new Long ( sendWindow ) , Boolean . valueOf ( restore ) } ) ; SourceStream stream = createStream ( streamSet , priority , reliability ) ; if ( pointTopoint ) { stream . initialiseSendWindow ( sendWindow , messageProcessor . getDefinedSendWindow ( ) ) ; if ( restore && destinationHandler . isLink ( ) && ! destinationHandler . isMQLink ( ) ) { stream . guessesInStream ( ) ; } } if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "createStream" , stream ) ; return stream ; }
Create a new Source Stream and store it in the given StreamSet

@param streamSet
@param priority
@param reliability
@param sendWindow size
@parm  boolean indicating whether this was called during a restore
@return a new SourceStream
@throws SIResourceException