psdi.iface.jms

Class KafkaErrorsCleanUp

  • java.lang.Object
    • psdi.iface.jms.KafkaErrorsCleanUp

  • public class KafkaErrorsCleanUp
extends java.lang.Object
    An automic object that provides the lock object for the tenant operation.

    • Field Summary

      Fields 
      Modifier and Type Field and Description
      protected static MXLogger logger
      Cron task specific logger.

    • Constructor Summary

      Constructors 
      Constructor and Description
      KafkaErrorsCleanUp()
      Default Constructor

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method and Description
      void clearMessageReprocessing(UserInfo userInfo)
      Deelete all message re-processing records which beyond retention time

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Field Detail

      • logger

        protected static final MXLogger logger
        Cron task specific logger.

    • Constructor Detail

      • KafkaErrorsCleanUp

        public KafkaErrorsCleanUp()
        Default Constructor

    • Method Detail

      • clearMessageReprocessing

        public void clearMessageReprocessing(UserInfo userInfo)
                              throws MXException,
                                     java.rmi.RemoteException
        Deelete all message re-processing records which beyond retention time
        Parameters:
        tenantid - tenant Id
        Throws:
        java.rmi.RemoteException
        MXException
Skip navigation links