OutboxItem

data class OutboxItem(id: Long?, type: OutboxType, status: OutboxStatus, payload: String, retries: Long, nextRun: Instant, lastExecution: Instant?, rerunAfter: Instant?, deleteAfter: Instant?, groupId: String?)

Represents an outbox item.

Parameters

groupId

an arbitrary value that can be used to group outbox items together. A null value indicates that the item is not part of a group.

Constructors

OutboxItem

fun OutboxItem(id: Long? = null, type: OutboxType, status: OutboxStatus, payload: String, retries: Long = 0, nextRun: Instant, lastExecution: Instant? = null, rerunAfter: Instant? = null, deleteAfter: Instant? = null, groupId: String? = null)

Functions

prepareForProcessing

fun prepareForProcessing(now: Instant, rerunAfter: Instant)

Resolves whether the item is eligible for processing based on its state (i.e. status, timestamps, etc.) and the current time (supplied as a parameter). If the item is eligible for processing, it is marked as such and its status and run timestamps are updated accordingly.

Properties

deleteAfter

var deleteAfter: Instant? = null

groupId

val groupId: String? = null

val id: Long? = null

lastExecution

var lastExecution: Instant? = null

markedForProcessing

var markedForProcessing: Boolean = false

is an internal flag that is used to determine if the item should be processed in the current monitor cycle. It is set by prepareForProcessing based on the item status and current time. Clients could (and should) ignore the value. Even if set earlier, its value be reset during the monitor cycle.

nextRun

var nextRun: Instant

payload

val payload: String

rerunAfter

var rerunAfter: Instant? = null

retries

var retries: Long = 0

status

var status: OutboxStatus

type

val type: OutboxType