private ControlNotFlushed createControlNotFlushed(SIBUuid8 target, SIBUuid12 stream, long reqID)
    throws SIResourceException
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.entry(tc, "createControlNotFlushed", new Object[] {target, stream, new Long(reqID)});

    ControlNotFlushed notFlushedMsg;

    // Create new message
    try
    {
      notFlushedMsg = _cmf.createNewControlNotFlushed();
    }
    catch (MessageCreateFailedException e)
    {
      // FFDC
      FFDCFilter.processException(
        e,
        "com.ibm.ws.sib.processor.impl.PubSubOutputHandler.createControlNotFlushed",
        "1:1498:1.164.1.5",
        this);
        
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      {
        SibTr.exception(tc, e);
        SibTr.exit(tc, "createControlNotFlushed", e);
      }
      
      SibTr.error(tc, "INTERNAL_MESSAGING_ERROR_CWSIP0002",
        new Object[] {
          "com.ibm.ws.sib.processor.impl.PubSubOutputHandler",
          "1:1510:1.164.1.5",
          e });

      throw new SIResourceException(
        nls.getFormattedMessage(
          "INTERNAL_MESSAGING_ERROR_CWSIP0002",
          new Object[] {
            "com.ibm.ws.sib.processor.impl.PubSubOutputHandler",
            "1:1518:1.164.1.5",
            e },
          null),
        e);
    }

    // As we are using the Guaranteed Header - set all the attributes as
    // well as the ones we want.
    SIMPUtils.setGuaranteedDeliveryProperties(notFlushedMsg,
        _messageProcessor.getMessagingEngineUuid(), 
        null,
        stream,
        null,
        _destinationHandler.getUuid(),
        ProtocolType.PUBSUBINPUT,
        GDConfig.PROTOCOL_VERSION);

    notFlushedMsg.setPriority(SIMPConstants.CTRL_MSG_PRIORITY);
    notFlushedMsg.setReliability(Reliability.ASSURED_PERSISTENT);
    
    notFlushedMsg.setRequestID(reqID);

    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.exit(tc, "createControlNotFlushed");

    return notFlushedMsg;
  }
private ControlNotFlushed createControlNotFlushed ( SIBUuid8 target , SIBUuid12 stream , long reqID ) throws SIResourceException { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "createControlNotFlushed" , new Object [ ] { target , stream , new Long ( reqID ) } ) ; ControlNotFlushed notFlushedMsg ; try { notFlushedMsg = _cmf . createNewControlNotFlushed ( ) ; } catch ( MessageCreateFailedException e ) { FFDCFilter . processException ( e , "com.ibm.ws.sib.processor.impl.PubSubOutputHandler.createControlNotFlushed" , "1:1498:1.164.1.5" , this ) ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) { SibTr . exception ( tc , e ) ; SibTr . exit ( tc , "createControlNotFlushed" , e ) ; } SibTr . error ( tc , "INTERNAL_MESSAGING_ERROR_CWSIP0002" , new Object [ ] { "com.ibm.ws.sib.processor.impl.PubSubOutputHandler" , "1:1510:1.164.1.5" , e } ) ; throw new SIResourceException ( nls . getFormattedMessage ( "INTERNAL_MESSAGING_ERROR_CWSIP0002" , new Object [ ] { "com.ibm.ws.sib.processor.impl.PubSubOutputHandler" , "1:1518:1.164.1.5" , e } , null ) , e ) ; } SIMPUtils . setGuaranteedDeliveryProperties ( notFlushedMsg , _messageProcessor . getMessagingEngineUuid ( ) , null , stream , null , _destinationHandler . getUuid ( ) , ProtocolType . PUBSUBINPUT , GDConfig . PROTOCOL_VERSION ) ; notFlushedMsg . setPriority ( SIMPConstants . CTRL_MSG_PRIORITY ) ; notFlushedMsg . setReliability ( Reliability . ASSURED_PERSISTENT ) ; notFlushedMsg . setRequestID ( reqID ) ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "createControlNotFlushed" ) ; return notFlushedMsg ; }
Creates a NOTFLUSHED message for sending

@param target The target cellule (er ME) for the message.
@param stream The UUID of the stream the message should be sent on.
@param reqID The request ID that the message answers.
@return the new NOTFLUSHED message.
@throws SIResourceException if the message can't be created.