spring/io.github.bluegroundltd.springoutbox.database/OutboxRepository

OutboxRepository

interface OutboxRepository : JpaRepository<OutboxItemEntity, Long>

Functions

abstract fun count(): Long

abstract fun <S : OutboxItemEntity> count(example: Example<S>): Long

abstract fun delete(entity: OutboxItemEntity)

abstract fun deleteAll()

abstract fun deleteAll(entities: MutableIterable<OutboxItemEntity>)

deleteAllByDeleteAfterLessThanEqual

abstract fun deleteAllByDeleteAfterLessThanEqual(referenceTimestamp: Instant)

abstract fun deleteAllById(ids: MutableIterable<Long>)

deleteAllByIdInBatch

abstract fun deleteAllByIdInBatch(ids: MutableIterable<Long>)

deleteAllInBatch

abstract fun deleteAllInBatch()

abstract fun deleteAllInBatch(entities: MutableIterable<OutboxItemEntity>)

abstract fun deleteById(id: Long)

open fun ~~deleteInBatch~~(entities: MutableIterable<OutboxItemEntity>)

abstract fun <S : OutboxItemEntity> exists(example: Example<S>): Boolean

abstract fun existsById(id: Long): Boolean

abstract override fun <S : OutboxItemEntity> findAll(example: Example<S>): MutableList<S>

abstract override fun <S : OutboxItemEntity> findAll(example: Example<S>, sort: Sort): MutableList<S>

abstract override fun findAll(): MutableList<OutboxItemEntity>

abstract override fun findAll(sort: Sort): MutableList<OutboxItemEntity>

abstract fun findAll(pageable: Pageable): Page<OutboxItemEntity>

abstract fun <S : OutboxItemEntity> findAll(example: Example<S>, pageable: Pageable): Page<S>

findAllByGroupIdInAndStatusNot

abstract fun findAllByGroupIdInAndStatusNot(groupIds: Set<String>, status: OutboxStatus): List<OutboxItemEntity>

abstract override fun findAllById(ids: MutableIterable<Long>): MutableList<OutboxItemEntity>

abstract fun <S : OutboxItemEntity, R : Any> findBy(example: Example<S>, queryFunction: Function<FluentQuery.FetchableFluentQuery<S>, R>): R

@Query(value = " select * from outbox_item where (status = :pendingStatus and next_run < :nextRunLessThan) or (status = :runningStatus and rerun_after < :rerunAfterLessThan) ", nativeQuery = true)

abstract fun findByFilter(pendingStatus: String, nextRunLessThan: Instant, runningStatus: String, rerunAfterLessThan: Instant): List<OutboxItemEntity>

@Lock(value = LockModeType.PESSIMISTIC_WRITE)

@QueryHints(value = [QueryHint(value = "100", name = "jakarta.persistence.lock.timeout")])

abstract override fun findById(id: Long): Optional<OutboxItemEntity>

abstract fun <S : OutboxItemEntity> findOne(example: Example<S>): Optional<S>

abstract fun flush()

abstract fun ~~getById~~(id: Long): OutboxItemEntity

abstract fun ~~getOne~~(id: Long): OutboxItemEntity

getReferenceById

abstract fun getReferenceById(id: Long): OutboxItemEntity

abstract fun <S : OutboxItemEntity> save(entity: S): S

abstract override fun <S : OutboxItemEntity> saveAll(entities: MutableIterable<S>): MutableList<S>

saveAllAndFlush

abstract fun <S : OutboxItemEntity> saveAllAndFlush(entities: MutableIterable<S>): MutableList<S>

abstract fun <S : OutboxItemEntity> saveAndFlush(entity: S): S