com.github.kuliginstepan.outbox.relational.autoconfigure

Class R2dbcOutboxRepository

java.lang.Object

com.github.kuliginstepan.outbox.relational.autoconfigure.R2dbcOutboxRepository

All Implemented Interfaces:

com.github.kuliginstepan.outbox.core.ReactiveOutboxRepository

public class R2dbcOutboxRepository
extends java.lang.Object
implements com.github.kuliginstepan.outbox.core.ReactiveOutboxRepository

Constructor Summary

Constructors

Constructor and Description
R2dbcOutboxRepository()

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Flux<com.github.kuliginstepan.outbox.core.OutboxEntity>	findUncompletedEntities()
reactor.core.publisher.Mono<java.lang.Void>	markCompleted(com.github.kuliginstepan.outbox.core.OutboxEntity entity)
reactor.core.publisher.Mono<java.lang.Void>	save(com.github.kuliginstepan.outbox.core.OutboxEntity entity)

Methods inherited from class java.lang.Object

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

Constructor Detail

R2dbcOutboxRepository

public R2dbcOutboxRepository()

Method Detail

save

public reactor.core.publisher.Mono<java.lang.Void> save(com.github.kuliginstepan.outbox.core.OutboxEntity entity)

Specified by:

save in interface com.github.kuliginstepan.outbox.core.ReactiveOutboxRepository

markCompleted

public reactor.core.publisher.Mono<java.lang.Void> markCompleted(com.github.kuliginstepan.outbox.core.OutboxEntity entity)

Specified by:

markCompleted in interface com.github.kuliginstepan.outbox.core.ReactiveOutboxRepository

findUncompletedEntities

public reactor.core.publisher.Flux<com.github.kuliginstepan.outbox.core.OutboxEntity> findUncompletedEntities()

Specified by:

findUncompletedEntities in interface com.github.kuliginstepan.outbox.core.ReactiveOutboxRepository