Class DroolsNorthbounder

    • Field Detail

      • NBI_NAME

        protected static final java.lang.String NBI_NAME
        The Constant NBI_NAME.
        See Also:
        Constant Field Values
    • Constructor Detail

      • DroolsNorthbounder

        public DroolsNorthbounder​(org.springframework.context.ApplicationContext context,
                                  DroolsNorthbounderConfigDao configDao,
                                  EventProxy eventProxy,
                                  java.lang.String engineName)
        Instantiates a new Drools northbounder.
        configDao - the configuration DAO
        engineName - the engine name
    • Method Detail

      • afterPropertiesSet

        public void afterPropertiesSet()
                                throws java.lang.Exception
        Specified by:
        afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean
      • accepts

        public boolean accepts​(NorthboundAlarm alarm)
        The abstraction makes a call here to determine if the alarm should be placed on the queue of alarms to be sent northerly.
        Specified by:
        accepts in class AbstractNorthbounder
        alarm - the alarm
        true, if successful
      • forwardAlarms

        public void forwardAlarms​(java.util.List<NorthboundAlarm> alarms)
                           throws NorthbounderException
        Each implementation of the AbstractNorthbounder has a nice queue (Nagle's algorithmic) and the worker thread that processes the queue calls this method to send alarms to the northern NMS.
        Specified by:
        forwardAlarms in class AbstractNorthbounder
        alarms - the alarms
        NorthbounderException - the northbounder exception
      • getKieSessionObjects

        public java.util.Collection<? extends java.lang.Object> getKieSessionObjects()
        Gets the kie session objects.
        the kie session objects
      • getKieSession

        public org.kie.api.runtime.KieSession getKieSession()
        Gets the kie session.
        the kie session
      • sendEvent

        public void sendEvent​(Event event)
        Send event.
        event - the event
      • isReady

        public boolean isReady()
        Description copied from interface: Northbounder
        Used to determine if the northbounder is ready to accept alarms. If no northbounders are ready, the caller can save resources by not creating and initializing the NorthboundAlarms. This method is called once after northbounder is registered and started. If the status were to change sometime after, the northbounder must re-register itself.
        Specified by:
        isReady in interface Northbounder
        true if the northbounder is ready to accept alarms, false otherwise.