private ControlAck createControlAckMessage(
    int priority,
    Reliability reliability,
    SIBUuid12 stream)
    throws SIResourceException
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.entry(tc, "createControlAckMessage");

    ControlAck ackMsg;

    // Create new AckMessage and send it
    try
    {
      ackMsg = _cmf.createNewControlAck();
    }
    catch (MessageCreateFailedException e)
    {
      // FFDC
      FFDCFilter.processException(
        e,
        "com.ibm.ws.sib.processor.impl.PubSubOutputHandler.createControlAckMessage",
        "1:1279:1.164.1.5",
        this);

      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      {
        SibTr.exception(tc, e);
        SibTr.exit(tc, "createControlAckMessage", e);
      }
      
      SibTr.error(tc, "INTERNAL_MESSAGING_ERROR_CWSIP0002",
        new Object[] {
          "com.ibm.ws.sib.processor.impl.PubSubOutputHandler",
          "1:1291:1.164.1.5",
          e });

      throw new SIResourceException(
        nls.getFormattedMessage(
          "INTERNAL_MESSAGING_ERROR_CWSIP0002",
          new Object[] {
            "com.ibm.ws.sib.processor.impl.PubSubOutputHandler",
            "1:1299: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(ackMsg,
        _messageProcessor.getMessagingEngineUuid(), 
        null,
        stream,
        null,
        _destinationHandler.getUuid(),
        ProtocolType.PUBSUBINPUT,
        GDConfig.PROTOCOL_VERSION);
  
    ackMsg.setPriority(priority);
    ackMsg.setReliability(reliability);

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

    return ackMsg;
  }
private ControlAck createControlAckMessage ( int priority , Reliability reliability , SIBUuid12 stream ) throws SIResourceException { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "createControlAckMessage" ) ; ControlAck ackMsg ; try { ackMsg = _cmf . createNewControlAck ( ) ; } catch ( MessageCreateFailedException e ) { FFDCFilter . processException ( e , "com.ibm.ws.sib.processor.impl.PubSubOutputHandler.createControlAckMessage" , "1:1279:1.164.1.5" , this ) ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) { SibTr . exception ( tc , e ) ; SibTr . exit ( tc , "createControlAckMessage" , e ) ; } SibTr . error ( tc , "INTERNAL_MESSAGING_ERROR_CWSIP0002" , new Object [ ] { "com.ibm.ws.sib.processor.impl.PubSubOutputHandler" , "1:1291:1.164.1.5" , e } ) ; throw new SIResourceException ( nls . getFormattedMessage ( "INTERNAL_MESSAGING_ERROR_CWSIP0002" , new Object [ ] { "com.ibm.ws.sib.processor.impl.PubSubOutputHandler" , "1:1299:1.164.1.5" , e } , null ) , e ) ; } SIMPUtils . setGuaranteedDeliveryProperties ( ackMsg , _messageProcessor . getMessagingEngineUuid ( ) , null , stream , null , _destinationHandler . getUuid ( ) , ProtocolType . PUBSUBINPUT , GDConfig . PROTOCOL_VERSION ) ; ackMsg . setPriority ( priority ) ; ackMsg . setReliability ( reliability ) ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "createControlAckMessage" ) ; return ackMsg ; }
Creates an ACK message for sending

@return the new ACK message

@throws SIResourceException if the message can't be created.