مقدمة في محرك التكامل

محرك التكامل يعمل كوسطاء رسائل يتلقى الرسائل من مصادر مختلفة.

• Business Services: تتلقى الرسائل من مصادر خارجية
• Business Processes: تعالج وتحول الرسائل
• Business Operations: ترسل الرسائل إلى أنظمة خارجية

Class MyApp.Service.HTTPService Extends EnsLib.REST.Service {
  Parameter ADAPTER = "EnsLib.HTTP.InboundAdapter";
  Method OnProcessInput(pInput, Output pOutput) As %Status {
    Set request = ##class(MyApp.Request).%New()
    Set request.Data = pInput.Read()
    Set sc = ..SendRequestSync("MyApp.Process.Main", request, .response)
    Set pOutput = response
    Return sc
  }
}

يمكنك تصميم مسارات معقدة باستخدام Business Processes.

Class MyApp.Process.Routing Extends EnsLib.MsgRouter.Process {
  XData RuleDefinition {
    
      
        
          
        
      
    
  }
}

مراقبة Production وتدفق الرسائل أمر أساسي لضمان التشغيل الصحيح.

// مراقبة حالة Production
ClassMethod CheckProductionStatus() {
  Set status = ##class(Ens.Director).GetProductionStatus(.productionName)
  Write "Production: ", productionName, !
  Write "Status: ", status, !
  
  // قائمة Business Hosts
  Set rs = ##class(Ens.Config.Production).GetConfigItems(productionName)
  While rs.%Next() {
    Set name = rs.%Get("Name")
    Set type = rs.%Get("BusinessType")
    Set enabled = rs.%Get("Enabled")
    Write type, ": ", name, " (", $Select(enabled:"Active", 1:"Disabled"), ")", !
  }
}

// عرض إحصائيات الرسائل
ClassMethod GetMessageStats() {
  &sql(SELECT COUNT(*) INTO :total FROM Ens.MessageHeader)
  &sql(SELECT COUNT(*) INTO :errors FROM Ens.MessageHeader WHERE Status = 'Error')
  Write "إجمالي الرسائل: ", total, !
  Write "الأخطاء: ", errors, !
}