Class QueueItem


  • public class QueueItem
    extends Object
    Representation of an item inserted into a task reactor queue.
    • Field Detail

      • id

        public final String id
        Item id.
      • timestamp

        public final Timestamp timestamp
        Item insertion timestamp.
      • resourceId

        public final String resourceId
        Ingested resource id.
      • cancelOngoingExecution

        public final boolean cancelOngoingExecution
        Should ongoing executions of the resource ingestion be cancelled.
      • workerPayload

        public final Variant workerPayload
        Additional payload for the worker
    • Method Detail

      • fromMap

        public static QueueItem fromMap​(Map<String,​Variant> map)
        Creates a new queue item from a specified map.
        Parameters:
        map - item map
        Returns:
        new queue item instance
      • fromRow

        public static QueueItem fromRow​(Row row)
        Creates a new queue item from a specified row.
        Parameters:
        row - item row
        Returns:
        new queue item instance