Package com.nt.udc.ndk.node

Class NPLProcessorNodeMT

java.lang.Object
com.nt.udc.ndk.node.DCNode
com.nt.udc.ndk.node.ProcessorNode
com.nt.udc.ndk.node.CommonProcessorNode
com.nt.udc.ndk.node.GeneralNPLProcessorNode
com.nt.udc.ndk.node.NPLProcessorNodeMT
All Implemented Interfaces:
AdminIfc, ConfigIfc, LoggerIfc, NodeHealthIfc, NodeStateManagementIfc, PropertyIfc, StateManagementIfc
Direct Known Subclasses:
HCDeduplicatorEP
public class NPLProcessorNodeMT extends GeneralNPLProcessorNode

  • Field Details

  • Constructor Details

    • NPLProcessorNodeMT

      public NPLProcessorNodeMT() throws NodeStartException
      Default Constructor
      Throws:
      NodeStartException - if there is a problem starting this cartridge

    • NPLProcessorNodeMT

      public NPLProcessorNodeMT(String[] args) throws NodeStartException
      Default Constructor for offline testing
      Parameters:
      args - Any startup arguments (see DCNode)
      ruleFile - A rule file reference (used only in offline testing)
      Throws:
      NodeStartException - if there is a problem starting this cartridge

  • Method Details

    • startup

      public void startup() throws NodeStartException
      Performs the necessary logic to start this cartridge
      Specified by:
      startup in interface AdminIfc
      Overrides:
      startup in class DCNode
      Throws:
      NodeStartException - if there is an issue starting this cartridge

    • setDCStreamHandler

      public void setDCStreamHandler(DCStreamHandler dcs)
      Overrides this from the super classes so that we can use our own Multi-Threaded Version of the NAR File Manager
      Overrides:
      setDCStreamHandler in class DCNode
      Parameters:
      dcs - The DC Stream Handler (ignored!)

    • warmRestartImplemented

      public boolean warmRestartImplemented()
      Allows this cartridge to implement a warm restart mode. This is necessary for OMC to call the startup() method.
      Overrides:
      warmRestartImplemented in class DCNode
      Returns:
      indication to tell OMC that this cartridge supports warn restarts

    • reconfigure

      public void reconfigure() throws NodeStartException
      Allows the cartridge to be re-configured without the need for stopping and restarting the cartridge
      Specified by:
      reconfigure in interface AdminIfc
      Overrides:
      reconfigure in class DCNode
      Throws:
      NodeStartException - if the cartridge cannot be reconfigured

    • shutdown

      public void shutdown()
      Performs the necessary logic to stop this cartridge
      Specified by:
      shutdown in interface AdminIfc
      Overrides:
      shutdown in class GeneralNPLProcessorNode

    • getMinorType

      public String getMinorType()
      Returns the cartridge's Minor Type
      Specified by:
      getMinorType in class DCNode
      Returns:
      The cartridge's minor type

    • getConfigDataGuiClass

      public String getConfigDataGuiClass()
      Returns the corresponding configuration GUI for this cartridge
      Specified by:
      getConfigDataGuiClass in class DCNode
      Returns:
      The configuration GUI Class

    • getCfgData

      protected void getCfgData()
      Initializes any configuration data this cartridge might need

    • shutdownFieldProcessors

      protected void shutdownFieldProcessors()
      Stops all of the NPL Field Processors

    • setFieldProcessors

      protected void setFieldProcessors(NPLFieldProcessor[] processors)
      Sets the list of NPL Field Processor objects for this cartridge
      Parameters:
      processors - A list of NPL Field Processors

    • setFieldProcessorThreads

      public void setFieldProcessorThreads(NPLFieldProcessor[] processors)
      Sets the NPL Field Processor Threads for this cartridge
      Parameters:
      processors - The list of NPL Field Processors

    • configureFieldProcessors

      protected NPLFieldProcessor[] configureFieldProcessors(int threads) throws NodeProcessingException
      Configures the NPL Field Processors
      Parameters:
      threads - The number of threads or NPL Field Processors to configure
      Returns:
      A list of NPL Field Processors
      Throws:
      NodeProcessingException - if there is any issue creating the NPL Field Processors

    • createFieldProcessor

      public DCFieldProcessor createFieldProcessor()

    • getIDCMethodHandler

      public IDCMethodHandler getIDCMethodHandler()
      This method returns an IDC Method Handler if there is one. A Method Handler can be registered with the NPL Field Processor and is similar to a Java Hook but more tightly integrated with the NPL/cartridge
      Returns:
      An IDC Method Handler or null if there isn't one.

    • main

      public static void main(String[] args)
      The main method is useful for debugging and development purposes. However, this method will never actually be called when the node is run within the actual application. The node is a Thread in the application, rather than a process.