Class QueueItemCleaner


  • public class QueueItemCleaner
    extends Object
    Class responsible for removal of obsolete items from the WorkItemQueue.
    • Method Detail

      • from

        public static QueueItemCleaner from​(Session session,
                                            Identifier instanceSchema)
        Returns a new instance of the QueueItemCleaner
        Parameters:
        session - Snowpark session object
        instanceSchema - Task Reactor schema instance
        Returns:
        a new cleaner instance
      • clean

        public void clean()
        Removes obsolete items from WorkItemQueue.