Uses of Interface
com.aim2be.platform.outbox.OutboxBackend
-
Uses of OutboxBackend in com.aim2be.platform.outbox
Classes in com.aim2be.platform.outbox that implement OutboxBackendModifier and TypeClassDescriptionclassDefault Postgres-backedOutboxBackend— the verbatim PG storage logic extracted fromOutboxPublisher+OutboxPollerWorkerduring Wave A.2 Phase 0a (design doc.planning/32-wave-a2-redis-outbox-design.mdrefinement #11) with ZERO behaviour change.Methods in com.aim2be.platform.outbox that return OutboxBackendModifier and TypeMethodDescriptionOutboxAutoConfiguration.outboxBackend(OutboxRecordRepository repository, OutboxPublishCompletion completion, OutboxProperties properties) DefaultOutboxBackend— the Postgres backend (Wave A.2 Phase 0a).Methods in com.aim2be.platform.outbox with parameters of type OutboxBackendModifier and TypeMethodDescriptionOutboxAutoConfiguration.outboxPollerWorker(OutboxBackend backend, org.springframework.kafka.core.KafkaTemplate<byte[], byte[]> kafkaTemplate, OutboxProperties properties, io.opentelemetry.api.OpenTelemetry openTelemetry, OutboxMetricsBinder metrics) Cold poller bean.OutboxAutoConfiguration.outboxPublisher(OutboxBackend backend, org.springframework.kafka.core.KafkaTemplate<byte[], byte[]> kafkaTemplate, io.github.resilience4j.circuitbreaker.CircuitBreaker outboxCircuitBreaker, io.opentelemetry.api.OpenTelemetry openTelemetry, OutboxMetricsBinder metrics, OutboxProperties properties) AFTER_COMMIT hot relay bean.Constructors in com.aim2be.platform.outbox with parameters of type OutboxBackendModifierConstructorDescriptionOutboxPollerWorker(OutboxBackend backend, org.springframework.kafka.core.KafkaTemplate<byte[], byte[]> kafkaTemplate, OutboxProperties properties, io.opentelemetry.api.OpenTelemetry openTelemetry, OutboxMetricsBinder metrics) Constructs the worker with all collaborators autowired byOutboxAutoConfiguration.OutboxPublisher(OutboxBackend backend, org.springframework.kafka.core.KafkaTemplate<byte[], byte[]> kafkaTemplate, io.github.resilience4j.circuitbreaker.CircuitBreaker circuitBreaker, io.opentelemetry.api.OpenTelemetry openTelemetry, OutboxMetricsBinder metrics, int maxRetries) Constructs an OutboxPublisher with all collaborators autowired byOutboxAutoConfiguration.