docs: protected static void handleCreateStream(
      DestinationManager DM,
      ControlCreateStream msg,
      MessageProcessor MP)
    {
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.entry(tc, "handleCreateStream", new Object[] {DM, msg, MP});
  
      ControlMessage reply = null;
  
      try
      {
        // Resolve the handler and attempt to attach to an 
        // existing local durable susbcription.
        SIBUuid12 handlerID     = msg.getGuaranteedTargetDestinationDefinitionUUID(); // attach requests require a target dest ID
        
        // Resolve the target BaseDestinationHandler
        BaseDestinationHandler handler = (BaseDestinationHandler) DM.getDestination(handlerID, false);
  
        handler.attachDurableFromRemote(msg);
      } 
      catch(SIDestinationLockedException e)
      {
        // No FFDC code needed
        // Cardinality error
        reply = createCardinalityInfo(MP, msg.getGuaranteedSourceMessagingEngineUUID(),msg.getRequestID(),1);
      }
      catch(Exception e)
      {
        // No FFDC code needed
        int      status = DurableConstants.STATUS_SUB_GENERAL_ERROR;
        SIBUuid8 sender = msg.getGuaranteedSourceMessagingEngineUUID(); 
        
        if (e instanceof SIDurableSubscriptionNotFoundException)
          status = DurableConstants.STATUS_SUB_NOT_FOUND;
        else if (e instanceof SIDurableSubscriptionMismatchException)
          status = DurableConstants.STATUS_SUB_MISMATCH_ERROR;       
        else if (e instanceof SINotAuthorizedException)
          status = DurableConstants.STATUS_NOT_AUTH_ERROR;
        else
        {
          // Anything else is logged and becomes a general error
          FFDCFilter.processException(
            e,
            "com.ibm.ws.sib.processor.impl.DurableOutputHandler.handleCreateStream",
            "1:454:1.45.1.1",
            DurableOutputHandler.class);
          SibTr.exception(tc, e);
        }
              
        reply = createDurableConfirm(MP, sender,msg.getRequestID(),status);
      }
  
      // Only send a reply on error conditions
      if (reply != null)
      {
        SIBUuid8 sender = msg.getGuaranteedSourceMessagingEngineUUID(); 
        MP.getMPIO().sendToMe(sender, SIMPConstants.CONTROL_MESSAGE_PRIORITY, reply);
      }
      
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.exit(tc, "handleCreateStream");
    }