Index (Outbox Framework 0.9.2 API)

A B C D E F G H I J L M N O P Q R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

AbstractJdbcAgeBasedPurger - Class in io.outbox.jdbc.purge: Base JDBC age-based purger that deletes all events older than a cutoff, regardless of status.
AbstractJdbcAgeBasedPurger() - Constructor for class io.outbox.jdbc.purge.AbstractJdbcAgeBasedPurger
AbstractJdbcAgeBasedPurger(String) - Constructor for class io.outbox.jdbc.purge.AbstractJdbcAgeBasedPurger
AbstractJdbcEventPurger - Class in io.outbox.jdbc.purge: Base JDBC event purger with default subquery-based SQL that works for H2 and PostgreSQL.
AbstractJdbcEventPurger() - Constructor for class io.outbox.jdbc.purge.AbstractJdbcEventPurger
AbstractJdbcEventPurger(String) - Constructor for class io.outbox.jdbc.purge.AbstractJdbcEventPurger
AbstractJdbcOutboxStore - Class in io.outbox.jdbc.store: Base JDBC outbox store with standard SQL implementations.
AbstractJdbcOutboxStore() - Constructor for class io.outbox.jdbc.store.AbstractJdbcOutboxStore
AbstractJdbcOutboxStore(String) - Constructor for class io.outbox.jdbc.store.AbstractJdbcOutboxStore
accept(EventEnvelope) - Method in interface io.outbox.dispatch.EventInterceptor.BeforeHook
accept(EventEnvelope, Exception) - Method in interface io.outbox.dispatch.EventInterceptor.AfterHook
after(EventInterceptor.AfterHook) - Static method in interface io.outbox.dispatch.EventInterceptor: Creates an interceptor with only an afterDispatch hook.
afterCommit(Runnable) - Method in class io.outbox.jdbc.tx.ThreadLocalTxContext
afterCommit(Runnable) - Method in interface io.outbox.spi.TxContext: Registers a callback to run after the current transaction commits.
afterCommit(Runnable) - Method in class io.outbox.spring.SpringTxContext
afterCommit(Runnable) - Method in class io.outbox.testing.StubTxContext
afterCommit(List<EventEnvelope>) - Method in class io.outbox.dispatch.DispatcherWriterHook
afterCommit(List<EventEnvelope>) - Method in class io.outbox.testing.RecordingWriterHook
afterCommit(List<EventEnvelope>) - Method in interface io.outbox.WriterHook: Called after the enclosing transaction commits successfully.
afterCommitCount() - Method in class io.outbox.testing.RecordingWriterHook: Returns the number of afterCommit invocations.
afterCommitCount() - Method in class io.outbox.testing.StubTxContext: Returns the number of pending afterCommit callbacks.
afterCommitInvocations() - Method in class io.outbox.testing.RecordingWriterHook: Returns all event lists passed to afterCommit.
afterDispatch(EventEnvelope, Exception) - Method in interface io.outbox.dispatch.EventInterceptor: Called after listener invocation (or after beforeDispatch failure).
afterRollback(Runnable) - Method in class io.outbox.jdbc.tx.ThreadLocalTxContext
afterRollback(Runnable) - Method in interface io.outbox.spi.TxContext: Registers a callback to run after the current transaction rolls back.
afterRollback(Runnable) - Method in class io.outbox.spring.SpringTxContext
afterRollback(Runnable) - Method in class io.outbox.testing.StubTxContext
afterRollback(List<EventEnvelope>) - Method in class io.outbox.testing.RecordingWriterHook
afterRollback(List<EventEnvelope>) - Method in interface io.outbox.WriterHook: Called after the enclosing transaction rolls back.
afterRollbackCount() - Method in class io.outbox.testing.RecordingWriterHook: Returns the number of afterRollback invocations.
afterRollbackCount() - Method in class io.outbox.testing.StubTxContext: Returns the number of pending afterRollback callbacks.
afterRollbackInvocations() - Method in class io.outbox.testing.RecordingWriterHook: Returns all event lists passed to afterRollback.
afterSingletonsInstantiated() - Method in class io.outbox.spring.boot.OutboxListenerRegistrar
afterWrite(List<EventEnvelope>) - Method in class io.outbox.testing.RecordingWriterHook
afterWrite(List<EventEnvelope>) - Method in interface io.outbox.WriterHook: Called after events are inserted but before the transaction commits.
afterWriteCount() - Method in class io.outbox.testing.RecordingWriterHook: Returns the number of afterWrite invocations.
afterWriteInvocations() - Method in class io.outbox.testing.RecordingWriterHook: Returns all event lists passed to afterWrite.
aggregateId() - Method in class io.outbox.EventEnvelope
aggregateId() - Method in record class io.outbox.model.OutboxEvent: Returns the value of the aggregateId record component.
aggregateId(String) - Method in class io.outbox.EventEnvelope.Builder: Sets the business identifier of the aggregate instance.
aggregateType() - Method in class io.outbox.EventEnvelope
aggregateType() - Method in record class io.outbox.model.OutboxEvent: Returns the value of the aggregateType record component.
aggregateType() - Element in annotation interface io.outbox.spring.boot.OutboxListener: Aggregate type name (string-based).
aggregateType(AggregateType) - Method in class io.outbox.EventEnvelope.Builder: Sets the aggregate type using a type-safe AggregateType for listener routing.
aggregateType(String) - Method in class io.outbox.EventEnvelope.Builder: Sets the aggregate type as a string for listener routing.
AggregateType - Interface in io.outbox: Represents an aggregate type identifier.
aggregateTypeClass() - Element in annotation interface io.outbox.spring.boot.OutboxListener: Aggregate type class (type-safe).
all() - Static method in class io.outbox.jdbc.store.JdbcOutboxStores: Returns all registered outbox stores.
all() - Method in class io.outbox.testing.InMemoryOutboxStore: Returns all stored events as a list.
Application - Class in io.outbox.demo.spring: Spring Boot demo for outbox framework.
Application - Class in io.outbox.demo.starter: Spring Boot Starter demo — zero-config auto-configuration.
Application() - Constructor for class io.outbox.demo.spring.Application
Application() - Constructor for class io.outbox.demo.starter.Application
attempts() - Method in record class io.outbox.dispatch.QueuedEvent: Returns the value of the attempts record component.
attempts() - Method in record class io.outbox.model.OutboxEvent: Returns the value of the attempts record component.
availableAt() - Method in class io.outbox.EventEnvelope: Returns the earliest time this event should be delivered, or null for immediate delivery.
availableAt() - Method in record class io.outbox.model.OutboxEvent: Returns the value of the availableAt record component.
availableAt(Instant) - Method in class io.outbox.EventEnvelope.Builder: Sets an absolute time at which this event becomes available for delivery.
availableCapacity() - Method in class io.outbox.dispatch.DispatcherPollerHandler
availableCapacity() - Method in interface io.outbox.poller.OutboxPollerHandler: Returns the number of events this handler can accept right now.

B

batchSize(int) - Method in class io.outbox.Outbox.AbstractBuilder: Sets the maximum number of events fetched per poll cycle.
batchSize(int) - Method in class io.outbox.Outbox.WriterOnlyBuilder
batchSize(int) - Method in class io.outbox.poller.OutboxPoller.Builder: Sets the maximum number of events fetched per poll cycle.
batchSize(int) - Method in class io.outbox.purge.OutboxPurgeScheduler.Builder: Sets the maximum number of events deleted per batch within a purge cycle.
before(EventInterceptor.BeforeHook) - Static method in interface io.outbox.dispatch.EventInterceptor: Creates an interceptor with only a beforeDispatch hook.
beforeDispatch(EventEnvelope) - Method in interface io.outbox.dispatch.EventInterceptor: Called before the event listener is invoked.
beforeWrite(List<EventEnvelope>) - Method in class io.outbox.testing.RecordingWriterHook
beforeWrite(List<EventEnvelope>) - Method in interface io.outbox.WriterHook: Called before events are inserted into the outbox store.
beforeWriteCount() - Method in class io.outbox.testing.RecordingWriterHook: Returns the number of beforeWrite invocations.
beforeWriteInvocations() - Method in class io.outbox.testing.RecordingWriterHook: Returns all event lists passed to beforeWrite.
begin() - Method in class io.outbox.jdbc.tx.JdbcTransactionManager: Begins a new transaction by obtaining a connection and binding it to the thread context.
BoundEventListener - Class in io.outbox: An EventListener bound to a specific (aggregateType, eventType) pair.
BoundEventListener(AggregateType, EventType) - Constructor for class io.outbox.BoundEventListener: Constructs a BoundEventListener using enum names for aggregate and event types.
BoundEventListener(String, String) - Constructor for class io.outbox.BoundEventListener: Constructs a BoundEventListener with the specified aggregate and event types.
build() - Method in class io.outbox.dispatch.OutboxDispatcher.Builder: Builds and starts the dispatcher.
build() - Method in class io.outbox.EventEnvelope.Builder: Builds an immutable EventEnvelope.
build() - Method in class io.outbox.Outbox.AbstractBuilder: Builds and starts the outbox composite.
build() - Method in class io.outbox.Outbox.MultiNodeBuilder
build() - Method in class io.outbox.Outbox.OrderedBuilder
build() - Method in class io.outbox.Outbox.SingleNodeBuilder
build() - Method in class io.outbox.Outbox.WriterOnlyBuilder
build() - Method in class io.outbox.poller.OutboxPoller.Builder: Builds the poller.
build() - Method in class io.outbox.purge.OutboxPurgeScheduler.Builder: Builds the purge scheduler.
build() - Method in class io.outbox.testing.OutboxTestSupport.Builder: Builds the test support with all fixtures wired together.
builder() - Static method in class io.outbox.dispatch.OutboxDispatcher
builder() - Static method in class io.outbox.poller.OutboxPoller
builder() - Static method in class io.outbox.purge.OutboxPurgeScheduler
builder(AggregateType, EventType) - Static method in class io.outbox.EventEnvelope: Creates a builder with a type-safe event type.
builder(EventType) - Static method in class io.outbox.EventEnvelope: Creates a builder with a type-safe event type.
builder(String) - Static method in class io.outbox.EventEnvelope: Creates a builder with a string event type.
builder(String, String) - Static method in class io.outbox.EventEnvelope: Creates a builder with a string event type.

C

claimAndMarkDone() - Method in class io.outbox.benchmark.OutboxPollerBenchmark
claimAndMarkDone_AverageTime(InfraControl, ThreadParams) - Method in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_claimAndMarkDone_jmhTest
claimAndMarkDone_avgt_jmhStub(InfraControl, RawResults, BenchmarkParams, IterationParams, ThreadParams, Blackhole, Control, int, OutboxPollerBenchmark_jmhType) - Static method in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_claimAndMarkDone_jmhTest
claimAndMarkDone_sample_jmhStub(InfraControl, RawResults, BenchmarkParams, IterationParams, ThreadParams, Blackhole, Control, int, SampleBuffer, int, long, int, OutboxPollerBenchmark_jmhType) - Static method in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_claimAndMarkDone_jmhTest
claimAndMarkDone_SampleTime(InfraControl, ThreadParams) - Method in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_claimAndMarkDone_jmhTest
claimAndMarkDone_SingleShotTime(InfraControl, ThreadParams) - Method in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_claimAndMarkDone_jmhTest
claimAndMarkDone_ss_jmhStub(InfraControl, RawResults, BenchmarkParams, IterationParams, ThreadParams, Blackhole, Control, int, int, OutboxPollerBenchmark_jmhType) - Static method in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_claimAndMarkDone_jmhTest
claimAndMarkDone_Throughput(InfraControl, ThreadParams) - Method in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_claimAndMarkDone_jmhTest
claimAndMarkDone_thrpt_jmhStub(InfraControl, RawResults, BenchmarkParams, IterationParams, ThreadParams, Blackhole, Control, int, OutboxPollerBenchmark_jmhType) - Static method in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_claimAndMarkDone_jmhTest
claimLocking(String, Duration) - Method in class io.outbox.Outbox.MultiNodeBuilder: Enables claim-based locking with an explicit owner ID.
claimLocking(String, Duration) - Method in class io.outbox.poller.OutboxPoller.Builder: Enables claim-based locking for multi-node deployments with an explicit owner ID.
claimLocking(Duration) - Method in class io.outbox.Outbox.MultiNodeBuilder: Enables claim-based locking with an auto-generated owner ID.
claimLocking(Duration) - Method in class io.outbox.poller.OutboxPoller.Builder: Enables claim-based locking for multi-node deployments with an auto-generated owner ID.
ClaimLocking() - Constructor for class io.outbox.spring.boot.OutboxProperties.ClaimLocking
claimPending(Connection, String, Instant, Instant, Duration, int) - Method in class io.outbox.jdbc.store.AbstractJdbcOutboxStore: H2-compatible two-phase claim: UPDATE with subquery, then SELECT claimed rows.
claimPending(Connection, String, Instant, Instant, Duration, int) - Method in class io.outbox.jdbc.store.MySqlOutboxStore
claimPending(Connection, String, Instant, Instant, Duration, int) - Method in class io.outbox.jdbc.store.PostgresOutboxStore
claimPending(Connection, String, Instant, Instant, Duration, int) - Method in interface io.outbox.spi.OutboxStore: Claims and returns pending events with owner-based locking for multi-instance deployments.
claimPending(Connection, String, Instant, Instant, Duration, int) - Method in class io.outbox.testing.InMemoryOutboxStore
clear() - Method in class io.outbox.testing.InMemoryOutboxStore: Clears all stored events.
close() - Method in class io.outbox.dispatch.OutboxDispatcher: Initiates graceful shutdown: stops accepting new events, drains remaining queued events within the configured drain timeout, then shuts down worker threads.
close() - Method in class io.outbox.jdbc.tx.JdbcTransactionManager.Transaction
close() - Method in class io.outbox.micrometer.MicrometerMetricsExporter: Removes all meters registered by this exporter from the registry.
close() - Method in class io.outbox.Outbox: Shuts down components in order: purge scheduler, poller, dispatcher.
close() - Method in class io.outbox.poller.OutboxPoller: Cancels the polling schedule and shuts down the scheduler thread.
close() - Method in class io.outbox.purge.OutboxPurgeScheduler: Cancels the purge schedule and shuts down the scheduler thread.
code() - Method in enum class io.outbox.model.EventStatus
COLD - Enum constant in enum class io.outbox.dispatch.QueuedEvent.Source: Event enqueued by the poller from the database.
coldQueueCapacity(int) - Method in class io.outbox.dispatch.OutboxDispatcher.Builder: Sets the bounded capacity of the cold queue (poller-sourced events).
coldQueueCapacity(int) - Method in class io.outbox.Outbox.MultiNodeBuilder: Sets the bounded capacity of the cold queue.
coldQueueCapacity(int) - Method in class io.outbox.Outbox.SingleNodeBuilder: Sets the bounded capacity of the cold queue.
coldQueueRemainingCapacity() - Method in class io.outbox.dispatch.OutboxDispatcher
commit() - Method in class io.outbox.jdbc.tx.JdbcTransactionManager.Transaction
computeDelayMs(int) - Method in class io.outbox.dispatch.ExponentialBackoffRetryPolicy
computeDelayMs(int) - Method in interface io.outbox.dispatch.RetryPolicy: Computes the delay in milliseconds before the next retry attempt.
connectionProvider(ConnectionProvider) - Method in class io.outbox.dispatch.OutboxDispatcher.Builder: Sets the connection provider for obtaining JDBC connections when marking events.
connectionProvider(ConnectionProvider) - Method in class io.outbox.Outbox.AbstractBuilder: Sets the connection provider for obtaining JDBC connections.
connectionProvider(ConnectionProvider) - Method in class io.outbox.poller.OutboxPoller.Builder: Sets the connection provider for obtaining JDBC connections when polling.
connectionProvider(ConnectionProvider) - Method in class io.outbox.purge.OutboxPurgeScheduler.Builder: Sets the connection provider for obtaining JDBC connections during purge operations.
connectionProvider(DataSource) - Method in class io.outbox.demo.spring.OutboxConfiguration
connectionProvider(DataSource) - Method in class io.outbox.spring.boot.OutboxAutoConfiguration
ConnectionProvider - Interface in io.outbox.spi: Provides JDBC connections for non-transactional outbox operations (e.g. dispatcher status updates, poller queries).
count(String) - Method in class io.outbox.dead.DeadEventManager: Counts DEAD events, optionally filtered by event type.
countDead(Connection, String) - Method in class io.outbox.jdbc.store.AbstractJdbcOutboxStore
countDead(Connection, String) - Method in interface io.outbox.spi.OutboxStore: Counts events in DEAD status, optionally filtered by event type.
countDead(Connection, String) - Method in class io.outbox.testing.InMemoryOutboxStore
create() - Static method in class io.outbox.testing.OutboxTestSupport: Creates a new builder.
createdAt() - Method in record class io.outbox.model.OutboxEvent: Returns the value of the createdAt record component.
currentConnection() - Method in class io.outbox.jdbc.tx.ThreadLocalTxContext
currentConnection() - Method in interface io.outbox.spi.TxContext: Returns the JDBC connection bound to the current transaction.
currentConnection() - Method in class io.outbox.spring.SpringTxContext
currentConnection() - Method in class io.outbox.testing.StubTxContext

D

DaemonThreadFactory - Class in io.outbox.util: Thread factory that creates named daemon threads with a sequential suffix.
DaemonThreadFactory(String) - Constructor for class io.outbox.util.DaemonThreadFactory
DataSourceConnectionProvider - Class in io.outbox.jdbc: ConnectionProvider backed by a DataSource.
DataSourceConnectionProvider(DataSource) - Constructor for class io.outbox.jdbc.DataSourceConnectionProvider
dead() - Static method in interface io.outbox.DispatchResult: Returns the singleton DispatchResult.Dead result with no reason.
dead(String) - Static method in interface io.outbox.DispatchResult: Creates a DispatchResult.Dead result with the given reason.
Dead(String) - Constructor for record class io.outbox.DispatchResult.Dead: Creates an instance of a Dead record class.
DEAD - Enum constant in enum class io.outbox.model.EventStatus: Permanently failed; no further retries.
DEAD - Static variable in interface io.outbox.DispatchResult: Singleton indicating the event should be immediately marked DEAD (no reason).
DeadEventManager - Class in io.outbox.dead: Convenience facade for querying, counting, and replaying DEAD events.
DeadEventManager(ConnectionProvider, OutboxStore) - Constructor for class io.outbox.dead.DeadEventManager
DEFAULT_TABLE - Static variable in class io.outbox.jdbc.purge.AbstractJdbcAgeBasedPurger
DEFAULT_TABLE - Static variable in class io.outbox.jdbc.purge.AbstractJdbcEventPurger
DEFAULT_TABLE - Static variable in class io.outbox.jdbc.store.AbstractJdbcOutboxStore
DEFAULT_TABLE - Static variable in class io.outbox.jdbc.TableNames
DefaultInFlightTracker - Class in io.outbox.dispatch: ConcurrentHashMap-based in-flight tracker with optional time-based expiry.
DefaultInFlightTracker() - Constructor for class io.outbox.dispatch.DefaultInFlightTracker: Creates a tracker with no TTL (entries persist until released).
DefaultInFlightTracker(long) - Constructor for class io.outbox.dispatch.DefaultInFlightTracker: Creates a tracker with a time-to-live for stale entries.
DefaultListenerRegistry - Class in io.outbox.registry: Thread-safe registry mapping (aggregateType, eventType) pairs to listeners.
DefaultListenerRegistry() - Constructor for class io.outbox.registry.DefaultListenerRegistry
DefaultOutboxWriter - Class in io.outbox: Default implementation of OutboxWriter that persists events via OutboxStore within an active TxContext transaction.
DefaultOutboxWriter(TxContext, OutboxStore) - Constructor for class io.outbox.DefaultOutboxWriter: Creates a writer with no writer hook (poller-only mode).
DefaultOutboxWriter(TxContext, OutboxStore, WriterHook) - Constructor for class io.outbox.DefaultOutboxWriter: Creates a writer with a writer hook for hot-path dispatch.
deferStart(boolean) - Method in class io.outbox.Outbox.AbstractBuilder: Defers poller startup until Outbox.start() is called explicitly.
delay() - Method in record class io.outbox.DispatchResult.RetryAfter: Returns the value of the delay record component.
deliverAfter(Duration) - Method in class io.outbox.EventEnvelope.Builder: Sets a relative delay from occurredAt after which this event becomes available for delivery.
detect(String) - Static method in class io.outbox.jdbc.store.JdbcOutboxStores: Auto-detects outbox store from a JDBC URL.
detect(DataSource) - Static method in class io.outbox.jdbc.store.JdbcOutboxStores: Auto-detects outbox store from a DataSource.
dispatcher(DataSourceConnectionProvider, AbstractJdbcOutboxStore, ListenerRegistry) - Method in class io.outbox.demo.spring.OutboxConfiguration
Dispatcher() - Constructor for class io.outbox.spring.boot.OutboxProperties.Dispatcher
DispatcherPollerHandler - Class in io.outbox.dispatch: Bridges OutboxPoller to the dispatcher's cold queue by implementing OutboxPollerHandler.
DispatcherPollerHandler(OutboxDispatcher) - Constructor for class io.outbox.dispatch.DispatcherPollerHandler
DispatcherWriterHook - Class in io.outbox.dispatch: Bridges OutboxWriter to the dispatcher's hot queue by implementing WriterHook.
DispatcherWriterHook(OutboxDispatcher) - Constructor for class io.outbox.dispatch.DispatcherWriterHook
DispatcherWriterHook(OutboxDispatcher, MetricsExporter) - Constructor for class io.outbox.dispatch.DispatcherWriterHook
DispatchResult - Interface in io.outbox: Result returned by EventListener.onEvent(EventEnvelope) to control post-dispatch behavior.
DispatchResult.Dead - Record Class in io.outbox: Event cannot be processed; immediately mark as DEAD without retry.
DispatchResult.Done - Record Class in io.outbox: Event processed successfully.
DispatchResult.RetryAfter - Record Class in io.outbox: Event not yet complete; reschedule after the specified delay.
done() - Static method in interface io.outbox.DispatchResult: Returns the singleton DispatchResult.Done result.
Done() - Constructor for record class io.outbox.DispatchResult.Done: Creates an instance of a Done record class.
DONE - Enum constant in enum class io.outbox.model.EventStatus: Successfully processed.
DONE - Static variable in interface io.outbox.DispatchResult: Singleton indicating successful processing.
drainTimeoutMs(long) - Method in class io.outbox.dispatch.OutboxDispatcher.Builder: Sets the maximum time in milliseconds to wait for in-flight events during shutdown.
drainTimeoutMs(long) - Method in class io.outbox.Outbox.AbstractBuilder: Sets the maximum time in milliseconds to wait for in-flight events during shutdown.
drainTimeoutMs(long) - Method in class io.outbox.Outbox.WriterOnlyBuilder

E

enqueueCold(QueuedEvent) - Method in class io.outbox.dispatch.OutboxDispatcher: Offers an event to the cold queue.
enqueueHot(QueuedEvent) - Method in class io.outbox.dispatch.OutboxDispatcher: Offers an event to the hot queue.
envelope() - Method in record class io.outbox.dispatch.QueuedEvent: Returns the value of the envelope record component.
equals(Object) - Method in record class io.outbox.dispatch.QueuedEvent: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.outbox.DispatchResult.Dead: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.outbox.DispatchResult.Done: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.outbox.DispatchResult.RetryAfter: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.outbox.model.OutboxEvent: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.outbox.StringAggregateType: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.outbox.StringEventType: Indicates whether some other object is "equal to" this one.
EVENT_ROW_MAPPER - Static variable in class io.outbox.jdbc.store.AbstractJdbcOutboxStore
EventController - Class in io.outbox.demo.spring
EventController - Class in io.outbox.demo.starter
EventController(OutboxWriter, JdbcTemplate) - Constructor for class io.outbox.demo.spring.EventController
EventController(OutboxWriter, JdbcTemplate) - Constructor for class io.outbox.demo.starter.EventController
EventEnvelope - Class in io.outbox: Immutable event envelope containing metadata and payload for an outbox event.
EventEnvelope.Builder - Class in io.outbox: Builder for EventEnvelope.
EventException - Exception in io.outbox: Base class for all outbox event processing exceptions.
EventException(String) - Constructor for exception io.outbox.EventException
EventException(String, Throwable) - Constructor for exception io.outbox.EventException
eventId() - Method in class io.outbox.EventEnvelope
eventId() - Method in record class io.outbox.model.OutboxEvent: Returns the value of the eventId record component.
eventId(String) - Method in class io.outbox.EventEnvelope.Builder: Sets a custom event identifier.
EventInterceptor - Interface in io.outbox.dispatch: Cross-cutting hook for observing or modifying event dispatch.
EventInterceptor.AfterHook - Interface in io.outbox.dispatch
EventInterceptor.BeforeHook - Interface in io.outbox.dispatch
EventListener - Interface in io.outbox: Listener that reacts to outbox events.
EventPurger - Interface in io.outbox.spi: Deletes terminal outbox events (DONE and DEAD) older than a given cutoff.
EventStatus - Enum Class in io.outbox.model: Lifecycle states of an outbox event.
eventType() - Method in class io.outbox.EventEnvelope
eventType() - Method in record class io.outbox.model.OutboxEvent: Returns the value of the eventType record component.
eventType() - Element in annotation interface io.outbox.spring.boot.OutboxListener: Event type name (string-based).
EventType - Interface in io.outbox: Represents an event type identifier.
eventTypeClass() - Element in annotation interface io.outbox.spring.boot.OutboxListener: Event type class (type-safe).
ExponentialBackoffRetryPolicy - Class in io.outbox.dispatch: Retry policy using exponential backoff with jitter.
ExponentialBackoffRetryPolicy(long, long) - Constructor for class io.outbox.dispatch.ExponentialBackoffRetryPolicy

F

fromJson(String, Class<T>) - Method in class io.outbox.gson.GsonJsonCodec
fromJson(String, Class<T>) - Method in interface io.outbox.spi.JsonCodec: Deserializes a JSON string into an object of the given type.
fromJson(String, Class<T>) - Method in class io.outbox.spring.boot.JacksonJsonCodec

G

get(String) - Static method in class io.outbox.jdbc.store.JdbcOutboxStores: Gets an outbox store by name.
getAggregateType() - Method in class io.outbox.BoundEventListener: Returns the aggregate type this listener is bound to.
getBaseDelayMs() - Method in class io.outbox.spring.boot.OutboxProperties.Retry
getBatchSize() - Method in class io.outbox.spring.boot.OutboxProperties.Poller
getBatchSize() - Method in class io.outbox.spring.boot.OutboxProperties.Purge
getClaimLocking() - Method in class io.outbox.spring.boot.OutboxProperties
getColdQueueCapacity() - Method in class io.outbox.spring.boot.OutboxProperties.Dispatcher
getConnection() - Method in class io.outbox.jdbc.DataSourceConnectionProvider
getConnection() - Method in interface io.outbox.spi.ConnectionProvider: Obtains a new JDBC connection.
getConnection() - Method in class io.outbox.testing.NoOpConnectionProvider
getDefault() - Static method in interface io.outbox.spi.JsonCodec: Returns the default implementation, resolved via programmatic override or ServiceLoader discovery.
getDispatcher() - Method in class io.outbox.spring.boot.OutboxProperties
getDrainTimeoutMs() - Method in class io.outbox.spring.boot.OutboxProperties.Dispatcher
getEventType() - Method in class io.outbox.BoundEventListener: Returns the event type this listener is bound to.
getHotQueueCapacity() - Method in class io.outbox.spring.boot.OutboxProperties.Dispatcher
getIntervalMs() - Method in class io.outbox.spring.boot.OutboxProperties.Poller
getIntervalSeconds() - Method in class io.outbox.spring.boot.OutboxProperties.Purge
getLockTimeout() - Method in class io.outbox.spring.boot.OutboxProperties.ClaimLocking
getMaxAttempts() - Method in class io.outbox.spring.boot.OutboxProperties.Dispatcher
getMaxDelayMs() - Method in class io.outbox.spring.boot.OutboxProperties.Retry
getMetrics() - Method in class io.outbox.spring.boot.OutboxProperties
getMode() - Method in class io.outbox.spring.boot.OutboxProperties
getNamePrefix() - Method in class io.outbox.spring.boot.OutboxProperties.Metrics
getOwnerId() - Method in class io.outbox.spring.boot.OutboxProperties.ClaimLocking
getPoller() - Method in class io.outbox.spring.boot.OutboxProperties
getPurge() - Method in class io.outbox.spring.boot.OutboxProperties
getRetention() - Method in class io.outbox.spring.boot.OutboxProperties.Purge
getRetry() - Method in class io.outbox.spring.boot.OutboxProperties
getSkipRecentMs() - Method in class io.outbox.spring.boot.OutboxProperties.Poller
getTableName() - Method in class io.outbox.spring.boot.OutboxProperties
getWorkerCount() - Method in class io.outbox.spring.boot.OutboxProperties.Dispatcher
GLOBAL - Static variable in interface io.outbox.AggregateType: Global aggregate type used when no specific aggregate type is set.
GsonJsonCodec - Class in io.outbox.gson: JsonCodec implementation backed by Gson.
GsonJsonCodec() - Constructor for class io.outbox.gson.GsonJsonCodec
GsonJsonCodec(Gson) - Constructor for class io.outbox.gson.GsonJsonCodec

H

H2AgeBasedPurger - Class in io.outbox.jdbc.purge: H2 age-based purger.
H2AgeBasedPurger() - Constructor for class io.outbox.jdbc.purge.H2AgeBasedPurger
H2AgeBasedPurger(String) - Constructor for class io.outbox.jdbc.purge.H2AgeBasedPurger
H2EventPurger - Class in io.outbox.jdbc.purge: H2 event purger.
H2EventPurger() - Constructor for class io.outbox.jdbc.purge.H2EventPurger
H2EventPurger(String) - Constructor for class io.outbox.jdbc.purge.H2EventPurger
H2OutboxStore - Class in io.outbox.jdbc.store: H2 outbox store.
H2OutboxStore() - Constructor for class io.outbox.jdbc.store.H2OutboxStore
H2OutboxStore(String) - Constructor for class io.outbox.jdbc.store.H2OutboxStore
handle(EventEnvelope, int) - Method in class io.outbox.dispatch.DispatcherPollerHandler
handle(EventEnvelope, int) - Method in interface io.outbox.poller.OutboxPollerHandler: Handles a polled event.
handler(OutboxPollerHandler) - Method in class io.outbox.poller.OutboxPoller.Builder: Sets the handler that receives polled events (typically a DispatcherPollerHandler).
hashCode() - Method in record class io.outbox.dispatch.QueuedEvent: Returns a hash code value for this object.
hashCode() - Method in record class io.outbox.DispatchResult.Dead: Returns a hash code value for this object.
hashCode() - Method in record class io.outbox.DispatchResult.Done: Returns a hash code value for this object.
hashCode() - Method in record class io.outbox.DispatchResult.RetryAfter: Returns a hash code value for this object.
hashCode() - Method in record class io.outbox.model.OutboxEvent: Returns a hash code value for this object.
hashCode() - Method in record class io.outbox.StringAggregateType: Returns a hash code value for this object.
hashCode() - Method in record class io.outbox.StringEventType: Returns a hash code value for this object.
headers() - Method in class io.outbox.EventEnvelope
headers(Map<String, String>) - Method in class io.outbox.EventEnvelope.Builder: Sets custom key-value metadata headers.
headersJson() - Method in record class io.outbox.model.OutboxEvent: Returns the value of the headersJson record component.
HOT - Enum constant in enum class io.outbox.dispatch.QueuedEvent.Source: Event enqueued directly via after-commit hook.
hotQueueCapacity(int) - Method in class io.outbox.dispatch.OutboxDispatcher.Builder: Sets the bounded capacity of the hot queue (after-commit events).
hotQueueCapacity(int) - Method in class io.outbox.Outbox.MultiNodeBuilder: Sets the bounded capacity of the hot queue.
hotQueueCapacity(int) - Method in class io.outbox.Outbox.SingleNodeBuilder: Sets the bounded capacity of the hot queue.

I

incrementColdEnqueued() - Method in class io.outbox.micrometer.MicrometerMetricsExporter
incrementColdEnqueued() - Method in interface io.outbox.spi.MetricsExporter: Increments the count of events enqueued via the cold (poller) path.
incrementColdEnqueued() - Method in class io.outbox.spi.MetricsExporter.Noop
incrementDispatchDead() - Method in class io.outbox.micrometer.MicrometerMetricsExporter
incrementDispatchDead() - Method in interface io.outbox.spi.MetricsExporter: Increments the count of events moved to DEAD (no more retries).
incrementDispatchDead() - Method in class io.outbox.spi.MetricsExporter.Noop
incrementDispatchDeferred() - Method in class io.outbox.micrometer.MicrometerMetricsExporter
incrementDispatchDeferred() - Method in interface io.outbox.spi.MetricsExporter: Increments the count of events deferred by a handler returning DispatchResult.RetryAfter.
incrementDispatchDeferred() - Method in class io.outbox.spi.MetricsExporter.Noop
incrementDispatchFailure() - Method in class io.outbox.micrometer.MicrometerMetricsExporter
incrementDispatchFailure() - Method in interface io.outbox.spi.MetricsExporter: Increments the count of events that failed and will be retried.
incrementDispatchFailure() - Method in class io.outbox.spi.MetricsExporter.Noop
incrementDispatchSuccess() - Method in class io.outbox.micrometer.MicrometerMetricsExporter
incrementDispatchSuccess() - Method in interface io.outbox.spi.MetricsExporter: Increments the count of events dispatched successfully.
incrementDispatchSuccess() - Method in class io.outbox.spi.MetricsExporter.Noop
incrementHotDropped() - Method in class io.outbox.micrometer.MicrometerMetricsExporter
incrementHotDropped() - Method in interface io.outbox.spi.MetricsExporter: Increments the count of events dropped because the hot queue was full.
incrementHotDropped() - Method in class io.outbox.spi.MetricsExporter.Noop
incrementHotEnqueued() - Method in class io.outbox.micrometer.MicrometerMetricsExporter
incrementHotEnqueued() - Method in interface io.outbox.spi.MetricsExporter: Increments the count of events successfully enqueued via the hot path.
incrementHotEnqueued() - Method in class io.outbox.spi.MetricsExporter.Noop
incrementHotSkippedDelayed() - Method in class io.outbox.micrometer.MicrometerMetricsExporter
incrementHotSkippedDelayed() - Method in interface io.outbox.spi.MetricsExporter: Increments the count of delayed events skipped on the hot path.
inFlightTracker(InFlightTracker) - Method in class io.outbox.dispatch.OutboxDispatcher.Builder: Sets a custom in-flight tracker for deduplicating concurrent event processing.
InFlightTracker - Interface in io.outbox.dispatch: Tracks in-flight events to prevent duplicate concurrent dispatch of the same event.
InMemoryOutboxStore - Class in io.outbox.testing: In-memory OutboxStore for unit testing without JDBC.
InMemoryOutboxStore() - Constructor for class io.outbox.testing.InMemoryOutboxStore
insertBatch(Connection, List<EventEnvelope>) - Method in class io.outbox.jdbc.store.AbstractJdbcOutboxStore
insertBatch(Connection, List<EventEnvelope>) - Method in interface io.outbox.spi.OutboxStore: Inserts multiple events in a batch with status NEW.
insertNew(Connection, EventEnvelope) - Method in class io.outbox.jdbc.store.AbstractJdbcOutboxStore
insertNew(Connection, EventEnvelope) - Method in interface io.outbox.spi.OutboxStore: Inserts a new event with status NEW.
insertNew(Connection, EventEnvelope) - Method in class io.outbox.testing.InMemoryOutboxStore
interceptor(EventInterceptor) - Method in class io.outbox.dispatch.OutboxDispatcher.Builder: Appends a single event interceptor for before/after dispatch hooks.
interceptor(EventInterceptor) - Method in class io.outbox.Outbox.AbstractBuilder: Appends a single event interceptor for before/after dispatch hooks.
interceptor(EventInterceptor) - Method in class io.outbox.Outbox.WriterOnlyBuilder
interceptors(List<EventInterceptor>) - Method in class io.outbox.dispatch.OutboxDispatcher.Builder: Appends multiple event interceptors for before/after dispatch hooks.
interceptors(List<EventInterceptor>) - Method in class io.outbox.Outbox.AbstractBuilder: Appends multiple event interceptors for before/after dispatch hooks.
interceptors(List<EventInterceptor>) - Method in class io.outbox.Outbox.WriterOnlyBuilder
intervalMs(long) - Method in class io.outbox.Outbox.AbstractBuilder: Sets the polling interval in milliseconds.
intervalMs(long) - Method in class io.outbox.Outbox.WriterOnlyBuilder
intervalMs(long) - Method in class io.outbox.poller.OutboxPoller.Builder: Sets the polling interval in milliseconds.
intervalSeconds(long) - Method in class io.outbox.purge.OutboxPurgeScheduler.Builder: Sets the interval in seconds between purge cycles.
io.outbox - package io.outbox: Root API for the outbox framework — a minimal, Spring-free transactional outbox with JDBC persistence and at-least-once delivery.
io.outbox.benchmark - package io.outbox.benchmark
io.outbox.benchmark.jmh_generated - package io.outbox.benchmark.jmh_generated
io.outbox.dead - package io.outbox.dead: Dead event tooling for querying, counting, and replaying events stuck in DEAD status.
io.outbox.demo - package io.outbox.demo
io.outbox.demo.multids - package io.outbox.demo.multids
io.outbox.demo.spring - package io.outbox.demo.spring
io.outbox.demo.starter - package io.outbox.demo.starter
io.outbox.dispatch - package io.outbox.dispatch: Hot-path event dispatcher with dual-queue processing.
io.outbox.gson - package io.outbox.gson
io.outbox.jdbc - package io.outbox.jdbc: JDBC infrastructure shared across sub-packages.
io.outbox.jdbc.purge - package io.outbox.jdbc.purge: JDBC-based EventPurger implementations.
io.outbox.jdbc.store - package io.outbox.jdbc.store: JDBC-based OutboxStore implementations.
io.outbox.jdbc.tx - package io.outbox.jdbc.tx: Manual JDBC transaction management.
io.outbox.micrometer - package io.outbox.micrometer: Micrometer bridge for exporting outbox metrics to Prometheus, Grafana, and other backends.
io.outbox.model - package io.outbox.model: Domain model objects for the outbox framework.
io.outbox.poller - package io.outbox.poller: Scheduled database poller as a fallback delivery mechanism.
io.outbox.purge - package io.outbox.purge: Scheduled purge of terminal outbox events to prevent table bloat.
io.outbox.registry - package io.outbox.registry: Listener routing by (aggregateType, eventType) pairs.
io.outbox.spi - package io.outbox.spi: Service Provider Interfaces (SPI) for extending the outbox framework.
io.outbox.spring - package io.outbox.spring: Spring transaction integration for the outbox framework.
io.outbox.spring.boot - package io.outbox.spring.boot: Spring Boot auto-configuration for the outbox framework.
io.outbox.testing - package io.outbox.testing: Test fixtures for unit testing code that uses the outbox framework.
io.outbox.util - package io.outbox.util: Shared internal utilities.
isDelayed() - Method in class io.outbox.EventEnvelope: Returns true if this event has a future delivery time.
isEnabled() - Method in class io.outbox.spring.boot.OutboxProperties.ClaimLocking
isEnabled() - Method in class io.outbox.spring.boot.OutboxProperties.Metrics
isEnabled() - Method in class io.outbox.spring.boot.OutboxProperties.Purge
isRunning() - Method in class io.outbox.spring.boot.OutboxLifecycle
isTransactionActive() - Method in class io.outbox.jdbc.tx.ThreadLocalTxContext
isTransactionActive() - Method in interface io.outbox.spi.TxContext: Returns true if a transaction is currently active on this thread.
isTransactionActive() - Method in class io.outbox.spring.SpringTxContext
isTransactionActive() - Method in class io.outbox.testing.StubTxContext

J

jacksonJsonCodec(ObjectMapper) - Method in class io.outbox.spring.boot.OutboxAutoConfiguration
JacksonJsonCodec - Class in io.outbox.spring.boot: JsonCodec implementation backed by Jackson ObjectMapper.
JacksonJsonCodec(ObjectMapper) - Constructor for class io.outbox.spring.boot.JacksonJsonCodec
JdbcOutboxStores - Class in io.outbox.jdbc.store: Registry for JDBC outbox stores with auto-detection support.
JdbcTemplate - Class in io.outbox.jdbc: Lightweight JDBC helper to reduce boilerplate in event store implementations.
JdbcTemplate.RowMapper<T> - Interface in io.outbox.jdbc
JdbcTransactionManager - Class in io.outbox.jdbc.tx: Lightweight transaction manager for manual JDBC usage.
JdbcTransactionManager(ConnectionProvider, ThreadLocalTxContext) - Constructor for class io.outbox.jdbc.tx.JdbcTransactionManager
JdbcTransactionManager.Transaction - Class in io.outbox.jdbc.tx: An active transaction handle.
jdbcUrlPrefixes() - Method in class io.outbox.jdbc.store.AbstractJdbcOutboxStore: JDBC URL prefixes this outbox store handles (e.g., "jdbc:mysql:", "jdbc:tidb:").
jdbcUrlPrefixes() - Method in class io.outbox.jdbc.store.H2OutboxStore
jdbcUrlPrefixes() - Method in class io.outbox.jdbc.store.MySqlOutboxStore
jdbcUrlPrefixes() - Method in class io.outbox.jdbc.store.PostgresOutboxStore
jsonCodec() - Method in class io.outbox.jdbc.store.AbstractJdbcOutboxStore
JsonCodec - Interface in io.outbox.spi: Codec for JSON serialization/deserialization used by the outbox framework.
jsonPlaceholder() - Method in class io.outbox.jdbc.store.AbstractJdbcOutboxStore: Returns the SQL placeholder expression for JSON/JSONB columns.
jsonPlaceholder() - Method in class io.outbox.jdbc.store.PostgresOutboxStore

L

listenerFor(String, String) - Method in class io.outbox.registry.DefaultListenerRegistry
listenerFor(String, String) - Method in interface io.outbox.registry.ListenerRegistry: Returns the single listener for the given (aggregateType, eventType), or null if none registered.
listenerRegistry() - Method in class io.outbox.demo.spring.OutboxConfiguration
listenerRegistry() - Method in class io.outbox.spring.boot.OutboxAutoConfiguration
listenerRegistry() - Method in class io.outbox.testing.OutboxTestSupport: Returns the listener registry.
listenerRegistry(ListenerRegistry) - Method in class io.outbox.dispatch.OutboxDispatcher.Builder: Sets the listener registry that maps (aggregateType, eventType) pairs to listeners.
listenerRegistry(ListenerRegistry) - Method in class io.outbox.Outbox.AbstractBuilder: Sets the listener registry that maps events to listeners.
listenerRegistry(ListenerRegistry) - Method in class io.outbox.Outbox.WriterOnlyBuilder
ListenerRegistry - Interface in io.outbox.registry: Registry for looking up event listeners by (aggregateType, eventType).
listEvents() - Method in class io.outbox.demo.spring.EventController
listEvents() - Method in class io.outbox.demo.starter.EventController

M

main(String[]) - Static method in class io.outbox.demo.multids.MultiDatasourceDemo
main(String[]) - Static method in class io.outbox.demo.OutboxDemo
main(String[]) - Static method in class io.outbox.demo.spring.Application
main(String[]) - Static method in class io.outbox.demo.starter.Application
map(ResultSet) - Method in interface io.outbox.jdbc.JdbcTemplate.RowMapper
markDead(Connection, String, String) - Method in class io.outbox.jdbc.store.AbstractJdbcOutboxStore
markDead(Connection, String, String) - Method in interface io.outbox.spi.OutboxStore: Marks an event as DEAD (permanently failed, no more retries).
markDead(Connection, String, String) - Method in class io.outbox.testing.InMemoryOutboxStore
markDeferred(Connection, String, Instant) - Method in class io.outbox.jdbc.store.AbstractJdbcOutboxStore
markDeferred(Connection, String, Instant) - Method in interface io.outbox.spi.OutboxStore: Marks an event as deferred (handler requested retry-after) without incrementing the attempt count or recording an error.
markDeferred(Connection, String, Instant) - Method in class io.outbox.testing.InMemoryOutboxStore
markDone(Connection, String) - Method in class io.outbox.jdbc.store.AbstractJdbcOutboxStore
markDone(Connection, String) - Method in interface io.outbox.spi.OutboxStore: Marks an event as DONE (successfully processed).
markDone(Connection, String) - Method in class io.outbox.testing.InMemoryOutboxStore
markRetry(Connection, String, Instant, String) - Method in class io.outbox.jdbc.store.AbstractJdbcOutboxStore
markRetry(Connection, String, Instant, String) - Method in interface io.outbox.spi.OutboxStore: Marks an event for retry with a scheduled next-attempt time.
markRetry(Connection, String, Instant, String) - Method in class io.outbox.testing.InMemoryOutboxStore
MAX_BATCH_ROWS - Static variable in class io.outbox.jdbc.store.AbstractJdbcOutboxStore
MAX_PAYLOAD_BYTES - Static variable in class io.outbox.EventEnvelope
maxAttempts(int) - Method in class io.outbox.dispatch.OutboxDispatcher.Builder: Sets the maximum number of delivery attempts before an event is marked DEAD.
maxAttempts(int) - Method in class io.outbox.Outbox.MultiNodeBuilder: Sets the maximum number of delivery attempts before marking DEAD.
maxAttempts(int) - Method in class io.outbox.Outbox.SingleNodeBuilder: Sets the maximum number of delivery attempts before marking DEAD.
metrics(MetricsExporter) - Method in class io.outbox.dispatch.OutboxDispatcher.Builder: Sets the metrics exporter for recording dispatch counters and queue depths.
metrics(MetricsExporter) - Method in class io.outbox.Outbox.AbstractBuilder: Sets the metrics exporter.
metrics(MetricsExporter) - Method in class io.outbox.poller.OutboxPoller.Builder: Sets the metrics exporter for recording poll lag and cold-enqueue counters.
Metrics() - Constructor for class io.outbox.spring.boot.OutboxProperties.Metrics
MetricsExporter - Interface in io.outbox.spi: Observability hook for exporting outbox counters and gauges to a metrics backend.
MetricsExporter.Noop - Class in io.outbox.spi: Default no-op implementation that discards all metrics.
micrometerMetricsExporter(MeterRegistry, OutboxProperties) - Method in class io.outbox.spring.boot.OutboxMicrometerAutoConfiguration
MicrometerMetricsExporter - Class in io.outbox.micrometer: Micrometer-based implementation of MetricsExporter.
MicrometerMetricsExporter(MeterRegistry) - Constructor for class io.outbox.micrometer.MicrometerMetricsExporter: Creates an exporter with the default metric name prefix "outbox".
MicrometerMetricsExporter(MeterRegistry, String) - Constructor for class io.outbox.micrometer.MicrometerMetricsExporter: Creates an exporter with a custom metric name prefix for multi-instance use.
MULTI_NODE - Enum constant in enum class io.outbox.spring.boot.OutboxProperties.Mode
MultiDatasourceDemo - Class in io.outbox.demo.multids: Demonstrates the multi-datasource outbox pattern: two independent H2 databases ("Orders" and "Inventory"), each with its own full outbox stack, sharing a stateless EventListener.
MultiDatasourceDemo() - Constructor for class io.outbox.demo.multids.MultiDatasourceDemo
multiNode() - Static method in class io.outbox.Outbox: Creates a builder for multi-node deployments with hot path + claim-based poller locking.
MySqlAgeBasedPurger - Class in io.outbox.jdbc.purge: MySQL age-based purger.
MySqlAgeBasedPurger() - Constructor for class io.outbox.jdbc.purge.MySqlAgeBasedPurger
MySqlAgeBasedPurger(String) - Constructor for class io.outbox.jdbc.purge.MySqlAgeBasedPurger
MySqlEventPurger - Class in io.outbox.jdbc.purge: MySQL event purger.
MySqlEventPurger() - Constructor for class io.outbox.jdbc.purge.MySqlEventPurger
MySqlEventPurger(String) - Constructor for class io.outbox.jdbc.purge.MySqlEventPurger
MySqlOutboxStore - Class in io.outbox.jdbc.store: MySQL outbox store.
MySqlOutboxStore() - Constructor for class io.outbox.jdbc.store.MySqlOutboxStore
MySqlOutboxStore(String) - Constructor for class io.outbox.jdbc.store.MySqlOutboxStore

N

name() - Method in interface io.outbox.AggregateType: Returns the string representation of this aggregate type.
name() - Method in interface io.outbox.EventType: Returns the string representation of this event type.
name() - Method in class io.outbox.jdbc.store.AbstractJdbcOutboxStore: Unique identifier for this outbox store (e.g., "mysql", "postgresql", "h2").
name() - Method in class io.outbox.jdbc.store.H2OutboxStore
name() - Method in class io.outbox.jdbc.store.MySqlOutboxStore
name() - Method in class io.outbox.jdbc.store.PostgresOutboxStore
name() - Method in record class io.outbox.StringAggregateType: Returns the value of the name record component.
name() - Method in record class io.outbox.StringEventType: Returns the value of the name record component.
NEW - Enum constant in enum class io.outbox.model.EventStatus: Newly inserted, awaiting dispatch.
newThread(Runnable) - Method in class io.outbox.util.DaemonThreadFactory
Noop() - Constructor for class io.outbox.spi.MetricsExporter.Noop
NOOP - Static variable in interface io.outbox.spi.MetricsExporter: No-op instance that discards all metrics.
NOOP - Static variable in interface io.outbox.WriterHook: No-op hook that does nothing; used as the default in OutboxWriter.
NoOpConnectionProvider - Class in io.outbox.testing: ConnectionProvider that always returns null.
NoOpConnectionProvider() - Constructor for class io.outbox.testing.NoOpConnectionProvider

O

occurredAt() - Method in class io.outbox.EventEnvelope
occurredAt(Instant) - Method in class io.outbox.EventEnvelope.Builder: Sets the event timestamp.
of(String) - Static method in record class io.outbox.StringAggregateType: Creates an aggregate type from a string.
of(String) - Static method in record class io.outbox.StringEventType: Creates an event type from a string.
ofJson(EventType, String) - Static method in class io.outbox.EventEnvelope: Creates an envelope with a type-safe event type and JSON payload.
ofJson(String, String) - Static method in class io.outbox.EventEnvelope: Creates an envelope with a string event type and JSON payload.
onEvent(EventEnvelope) - Method in class io.outbox.demo.starter.OrderPlacedListener
onEvent(EventEnvelope) - Method in class io.outbox.demo.starter.UserCreatedListener
onEvent(EventEnvelope) - Method in interface io.outbox.EventListener: Processes an outbox envelope and returns a DispatchResult to control post-dispatch behavior.
onReady(ApplicationReadyEvent) - Method in class io.outbox.demo.spring.OutboxConfiguration
ordered() - Static method in class io.outbox.Outbox: Creates a builder for ordered delivery (poller-only, single worker, no retry).
ORDERED - Enum constant in enum class io.outbox.spring.boot.OutboxProperties.Mode
OrderPlacedListener - Class in io.outbox.demo.starter
OrderPlacedListener() - Constructor for class io.outbox.demo.starter.OrderPlacedListener
outbox(OutboxProperties, ConnectionProvider, TxContext, AbstractJdbcOutboxStore, DefaultListenerRegistry, ObjectProvider<MetricsExporter>, ObjectProvider<EventInterceptor>) - Method in class io.outbox.spring.boot.OutboxAutoConfiguration
Outbox - Class in io.outbox: Composite entry point that wires an OutboxDispatcher, OutboxPoller, and OutboxWriter into a single AutoCloseable unit.
Outbox.AbstractBuilder<B extends Outbox.AbstractBuilder<B>> - Class in io.outbox: Base builder with shared required and optional parameters.
Outbox.MultiNodeBuilder - Class in io.outbox: Builder for multi-node deployments: hot path + claim-based poller locking.
Outbox.OrderedBuilder - Class in io.outbox: Builder for ordered delivery: poller-only, single worker, no retry.
Outbox.SingleNodeBuilder - Class in io.outbox: Builder for single-node deployments: hot path + poller fallback.
Outbox.WriterOnlyBuilder - Class in io.outbox: Builder for writer-only (CDC) mode: no dispatcher or poller.
OutboxAutoConfiguration - Class in io.outbox.spring.boot: Auto-configuration for the outbox framework.
OutboxAutoConfiguration() - Constructor for class io.outbox.spring.boot.OutboxAutoConfiguration
OutboxConfiguration - Class in io.outbox.demo.spring
OutboxConfiguration() - Constructor for class io.outbox.demo.spring.OutboxConfiguration
OutboxDemo - Class in io.outbox.demo: Simple demo showing outbox framework usage without Spring.
OutboxDemo() - Constructor for class io.outbox.demo.OutboxDemo
OutboxDispatchBenchmark - Class in io.outbox.benchmark: Measures hot-path end-to-end latency: write -> afterCommit -> dispatch -> listener callback.
OutboxDispatchBenchmark() - Constructor for class io.outbox.benchmark.OutboxDispatchBenchmark
OutboxDispatchBenchmark_jmhType - Class in io.outbox.benchmark.jmh_generated
OutboxDispatchBenchmark_jmhType() - Constructor for class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_jmhType
OutboxDispatchBenchmark_jmhType_B1 - Class in io.outbox.benchmark.jmh_generated
OutboxDispatchBenchmark_jmhType_B1() - Constructor for class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_jmhType_B1
OutboxDispatchBenchmark_jmhType_B2 - Class in io.outbox.benchmark.jmh_generated
OutboxDispatchBenchmark_jmhType_B2() - Constructor for class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_jmhType_B2
OutboxDispatchBenchmark_jmhType_B3 - Class in io.outbox.benchmark.jmh_generated
OutboxDispatchBenchmark_jmhType_B3() - Constructor for class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_jmhType_B3
OutboxDispatchBenchmark_writeAndDispatch_jmhTest - Class in io.outbox.benchmark.jmh_generated
OutboxDispatchBenchmark_writeAndDispatch_jmhTest() - Constructor for class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_writeAndDispatch_jmhTest
OutboxDispatcher - Class in io.outbox.dispatch: Dual-queue event processor that dispatches outbox events to registered listeners.
OutboxDispatcher.Builder - Class in io.outbox.dispatch: Builder for OutboxDispatcher.
OutboxEvent - Record Class in io.outbox.model: Read-only record representing a persisted outbox event row, as returned by the poller and dispatcher when reading from the database.
OutboxEvent(String, String, String, String, String, String, String, int, Instant, Instant) - Constructor for record class io.outbox.model.OutboxEvent: Creates an instance of a OutboxEvent record class.
outboxLifecycle(Outbox) - Method in class io.outbox.spring.boot.OutboxAutoConfiguration
OutboxLifecycle - Class in io.outbox.spring.boot: Manages the outbox lifecycle: starts the poller after all listeners are registered, and stops the poller/dispatcher during application shutdown.
OutboxLifecycle(Outbox) - Constructor for class io.outbox.spring.boot.OutboxLifecycle
OutboxListener - Annotation Interface in io.outbox.spring.boot: Marks a Spring bean as an outbox event listener.
outboxListenerRegistrar(ListableBeanFactory, DefaultListenerRegistry) - Method in class io.outbox.spring.boot.OutboxAutoConfiguration
OutboxListenerRegistrar - Class in io.outbox.spring.boot: Scans for beans annotated with OutboxListener and registers them in the DefaultListenerRegistry.
OutboxListenerRegistrar(ListableBeanFactory, DefaultListenerRegistry) - Constructor for class io.outbox.spring.boot.OutboxListenerRegistrar
OutboxMicrometerAutoConfiguration - Class in io.outbox.spring.boot: Auto-configuration for Micrometer metrics integration.
OutboxMicrometerAutoConfiguration() - Constructor for class io.outbox.spring.boot.OutboxMicrometerAutoConfiguration
outboxPoller(DataSourceConnectionProvider, AbstractJdbcOutboxStore, OutboxDispatcher) - Method in class io.outbox.demo.spring.OutboxConfiguration
OutboxPoller - Class in io.outbox.poller: Scheduled database scanner that polls for pending outbox events as a fallback when the hot path is unavailable or events are dropped.
OutboxPoller.Builder - Class in io.outbox.poller: Builder for OutboxPoller.
OutboxPollerBenchmark - Class in io.outbox.benchmark: Measures poller throughput: pollPending/claimPending + markDone per batch.
OutboxPollerBenchmark() - Constructor for class io.outbox.benchmark.OutboxPollerBenchmark
OutboxPollerBenchmark_claimAndMarkDone_jmhTest - Class in io.outbox.benchmark.jmh_generated
OutboxPollerBenchmark_claimAndMarkDone_jmhTest() - Constructor for class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_claimAndMarkDone_jmhTest
OutboxPollerBenchmark_jmhType - Class in io.outbox.benchmark.jmh_generated
OutboxPollerBenchmark_jmhType() - Constructor for class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_jmhType
OutboxPollerBenchmark_jmhType_B1 - Class in io.outbox.benchmark.jmh_generated
OutboxPollerBenchmark_jmhType_B1() - Constructor for class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_jmhType_B1
OutboxPollerBenchmark_jmhType_B2 - Class in io.outbox.benchmark.jmh_generated
OutboxPollerBenchmark_jmhType_B2() - Constructor for class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_jmhType_B2
OutboxPollerBenchmark_jmhType_B3 - Class in io.outbox.benchmark.jmh_generated
OutboxPollerBenchmark_jmhType_B3() - Constructor for class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_jmhType_B3
OutboxPollerBenchmark_pollAndMarkDone_jmhTest - Class in io.outbox.benchmark.jmh_generated
OutboxPollerBenchmark_pollAndMarkDone_jmhTest() - Constructor for class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_pollAndMarkDone_jmhTest
OutboxPollerHandler - Interface in io.outbox.poller: Callback for events discovered by the OutboxPoller.
OutboxProperties - Class in io.outbox.spring.boot: Configuration properties for the outbox framework.
OutboxProperties() - Constructor for class io.outbox.spring.boot.OutboxProperties
OutboxProperties.ClaimLocking - Class in io.outbox.spring.boot
OutboxProperties.Dispatcher - Class in io.outbox.spring.boot
OutboxProperties.Metrics - Class in io.outbox.spring.boot
OutboxProperties.Mode - Enum Class in io.outbox.spring.boot
OutboxProperties.Poller - Class in io.outbox.spring.boot
OutboxProperties.Purge - Class in io.outbox.spring.boot
OutboxProperties.Retry - Class in io.outbox.spring.boot
OutboxPurgeScheduler - Class in io.outbox.purge: Scheduled component that purges terminal outbox events (DONE and DEAD) older than a configurable retention period.
OutboxPurgeScheduler.Builder - Class in io.outbox.purge: Builder for OutboxPurgeScheduler.
outboxStore(OutboxStore) - Method in class io.outbox.dispatch.OutboxDispatcher.Builder: Sets the outbox store used to update event status (DONE, RETRY, DEAD).
outboxStore(OutboxStore) - Method in class io.outbox.Outbox.AbstractBuilder: Sets the outbox store for event persistence.
outboxStore(OutboxStore) - Method in class io.outbox.poller.OutboxPoller.Builder: Sets the outbox store used to query and claim pending events.
outboxStore(DataSource) - Method in class io.outbox.demo.spring.OutboxConfiguration
outboxStore(DataSource, OutboxProperties) - Method in class io.outbox.spring.boot.OutboxAutoConfiguration
OutboxStore - Interface in io.outbox.spi: Persistence contract for outbox events, managing status transitions through the lifecycle: NEW → DONE, NEW → RETRY → DONE, or NEW → DEAD.
OutboxStoreException - Exception in io.outbox.jdbc: Unchecked exception wrapping JDBC errors thrown by AbstractJdbcOutboxStore and its subclasses.
OutboxStoreException(String, Throwable) - Constructor for exception io.outbox.jdbc.OutboxStoreException
OutboxTestSupport - Class in io.outbox.testing: Convenience builder for setting up outbox test fixtures without a database.
OutboxTestSupport.Builder - Class in io.outbox.testing: Builder for OutboxTestSupport.
OutboxWriteBenchmark - Class in io.outbox.benchmark: Measures OutboxWriter.write() throughput (ops/sec) within a JDBC transaction.
OutboxWriteBenchmark() - Constructor for class io.outbox.benchmark.OutboxWriteBenchmark
OutboxWriteBenchmark_jmhType - Class in io.outbox.benchmark.jmh_generated
OutboxWriteBenchmark_jmhType() - Constructor for class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_jmhType
OutboxWriteBenchmark_jmhType_B1 - Class in io.outbox.benchmark.jmh_generated
OutboxWriteBenchmark_jmhType_B1() - Constructor for class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_jmhType_B1
OutboxWriteBenchmark_jmhType_B2 - Class in io.outbox.benchmark.jmh_generated
OutboxWriteBenchmark_jmhType_B2() - Constructor for class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_jmhType_B2
OutboxWriteBenchmark_jmhType_B3 - Class in io.outbox.benchmark.jmh_generated
OutboxWriteBenchmark_jmhType_B3() - Constructor for class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_jmhType_B3
OutboxWriteBenchmark_writeEvent_jmhTest - Class in io.outbox.benchmark.jmh_generated
OutboxWriteBenchmark_writeEvent_jmhTest() - Constructor for class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_writeEvent_jmhTest
outboxWriter(Outbox) - Method in class io.outbox.spring.boot.OutboxAutoConfiguration
outboxWriter(TxContext, AbstractJdbcOutboxStore, OutboxDispatcher) - Method in class io.outbox.demo.spring.OutboxConfiguration
OutboxWriter - Interface in io.outbox: Primary entry point for writing events to the outbox within an active transaction.

P

parseStringMap(String) - Method in class io.outbox.gson.GsonJsonCodec
parseStringMap(String) - Method in interface io.outbox.spi.JsonCodec: Parses a JSON object string into a string map.
parseStringMap(String) - Method in class io.outbox.spring.boot.JacksonJsonCodec
payload(Class<T>) - Method in class io.outbox.EventEnvelope: Deserializes the JSON payload into an object of the given type using the default JsonCodec.
payloadJson() - Method in class io.outbox.EventEnvelope
payloadJson() - Method in record class io.outbox.model.OutboxEvent: Returns the value of the payloadJson record component.
payloadJson(String) - Method in class io.outbox.EventEnvelope.Builder: Sets the event payload as a JSON string.
PayloadParseException - Exception in io.outbox: Thrown when an event payload cannot be deserialized from JSON.
PayloadParseException(String) - Constructor for exception io.outbox.PayloadParseException
PayloadParseException(String, Throwable) - Constructor for exception io.outbox.PayloadParseException
PENDING_STATUS_IN - Static variable in class io.outbox.jdbc.store.AbstractJdbcOutboxStore
poll() - Method in class io.outbox.poller.OutboxPoller: Executes a single poll cycle.
pollAndMarkDone() - Method in class io.outbox.benchmark.OutboxPollerBenchmark
pollAndMarkDone_AverageTime(InfraControl, ThreadParams) - Method in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_pollAndMarkDone_jmhTest
pollAndMarkDone_avgt_jmhStub(InfraControl, RawResults, BenchmarkParams, IterationParams, ThreadParams, Blackhole, Control, int, OutboxPollerBenchmark_jmhType) - Static method in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_pollAndMarkDone_jmhTest
pollAndMarkDone_sample_jmhStub(InfraControl, RawResults, BenchmarkParams, IterationParams, ThreadParams, Blackhole, Control, int, SampleBuffer, int, long, int, OutboxPollerBenchmark_jmhType) - Static method in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_pollAndMarkDone_jmhTest
pollAndMarkDone_SampleTime(InfraControl, ThreadParams) - Method in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_pollAndMarkDone_jmhTest
pollAndMarkDone_SingleShotTime(InfraControl, ThreadParams) - Method in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_pollAndMarkDone_jmhTest
pollAndMarkDone_ss_jmhStub(InfraControl, RawResults, BenchmarkParams, IterationParams, ThreadParams, Blackhole, Control, int, int, OutboxPollerBenchmark_jmhType) - Static method in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_pollAndMarkDone_jmhTest
pollAndMarkDone_Throughput(InfraControl, ThreadParams) - Method in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_pollAndMarkDone_jmhTest
pollAndMarkDone_thrpt_jmhStub(InfraControl, RawResults, BenchmarkParams, IterationParams, ThreadParams, Blackhole, Control, int, OutboxPollerBenchmark_jmhType) - Static method in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_pollAndMarkDone_jmhTest
Poller() - Constructor for class io.outbox.spring.boot.OutboxProperties.Poller
pollPending(Connection, Instant, Duration, int) - Method in class io.outbox.jdbc.store.AbstractJdbcOutboxStore
pollPending(Connection, Instant, Duration, int) - Method in interface io.outbox.spi.OutboxStore: Retrieves pending events eligible for processing (no locking).
pollPending(Connection, Instant, Duration, int) - Method in class io.outbox.testing.InMemoryOutboxStore
PostgresAgeBasedPurger - Class in io.outbox.jdbc.purge: PostgreSQL age-based purger.
PostgresAgeBasedPurger() - Constructor for class io.outbox.jdbc.purge.PostgresAgeBasedPurger
PostgresAgeBasedPurger(String) - Constructor for class io.outbox.jdbc.purge.PostgresAgeBasedPurger
PostgresEventPurger - Class in io.outbox.jdbc.purge: PostgreSQL event purger.
PostgresEventPurger() - Constructor for class io.outbox.jdbc.purge.PostgresEventPurger
PostgresEventPurger(String) - Constructor for class io.outbox.jdbc.purge.PostgresEventPurger
PostgresOutboxStore - Class in io.outbox.jdbc.store: PostgreSQL outbox store.
PostgresOutboxStore() - Constructor for class io.outbox.jdbc.store.PostgresOutboxStore
PostgresOutboxStore(String) - Constructor for class io.outbox.jdbc.store.PostgresOutboxStore
publishOrderPlaced(String, double) - Method in class io.outbox.demo.spring.EventController
publishOrderPlaced(String, double) - Method in class io.outbox.demo.starter.EventController
publishUserCreated(String) - Method in class io.outbox.demo.spring.EventController
publishUserCreated(String) - Method in class io.outbox.demo.starter.EventController
purge(Connection, Instant, int) - Method in class io.outbox.jdbc.purge.AbstractJdbcAgeBasedPurger: Deletes all events older than before, up to limit rows.
purge(Connection, Instant, int) - Method in class io.outbox.jdbc.purge.AbstractJdbcEventPurger: Deletes terminal events older than before, up to limit rows.
purge(Connection, Instant, int) - Method in class io.outbox.jdbc.purge.MySqlAgeBasedPurger
purge(Connection, Instant, int) - Method in class io.outbox.jdbc.purge.MySqlEventPurger
purge(Connection, Instant, int) - Method in interface io.outbox.spi.EventPurger: Deletes terminal events (DONE + DEAD) created before the given cutoff.
Purge() - Constructor for class io.outbox.spring.boot.OutboxProperties.Purge
purgeBatchSize(int) - Method in class io.outbox.Outbox.WriterOnlyBuilder: Sets the maximum number of events deleted per batch within a purge cycle.
purgeIntervalSeconds(long) - Method in class io.outbox.Outbox.WriterOnlyBuilder: Sets the interval in seconds between purge cycles.
purger(EventPurger) - Method in class io.outbox.Outbox.WriterOnlyBuilder: Sets the age-based purger for cleaning up old events.
purger(EventPurger) - Method in class io.outbox.purge.OutboxPurgeScheduler.Builder: Sets the purge strategy implementation that deletes terminal events.
purgeRetention(Duration) - Method in class io.outbox.Outbox.WriterOnlyBuilder: Sets the retention period for the purge scheduler.

Q

query(String, String, int) - Method in class io.outbox.dead.DeadEventManager: Queries DEAD events with optional filters.
query(Connection, String, JdbcTemplate.RowMapper<T>, Object...) - Static method in class io.outbox.jdbc.JdbcTemplate: Execute SELECT, map rows.
queryDead(Connection, String, String, int) - Method in class io.outbox.jdbc.store.AbstractJdbcOutboxStore
queryDead(Connection, String, String, int) - Method in interface io.outbox.spi.OutboxStore: Queries events in DEAD status with optional filters.
queryDead(Connection, String, String, int) - Method in class io.outbox.testing.InMemoryOutboxStore
QueuedEvent - Record Class in io.outbox.dispatch: Internal wrapper pairing an EventEnvelope with its origin queue and attempt count.
QueuedEvent(EventEnvelope, QueuedEvent.Source, int) - Constructor for record class io.outbox.dispatch.QueuedEvent: Creates an instance of a QueuedEvent record class.
QueuedEvent.Source - Enum Class in io.outbox.dispatch: Indicates whether an event arrived via the hot path or cold (poller) path.

R

readyInvocation - Variable in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_jmhType_B2
readyInvocation - Variable in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_jmhType_B2
readyInvocation - Variable in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_jmhType_B2
readyIteration - Variable in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_jmhType_B2
readyIteration - Variable in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_jmhType_B2
readyIteration - Variable in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_jmhType_B2
readyTrial - Variable in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_jmhType_B2
readyTrial - Variable in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_jmhType_B2
readyTrial - Variable in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_jmhType_B2
reason() - Method in record class io.outbox.DispatchResult.Dead: Returns the value of the reason record component.
recentCutoff(Instant, Duration) - Method in class io.outbox.jdbc.store.AbstractJdbcOutboxStore
recordDispatchLatencyMs(long) - Method in class io.outbox.micrometer.MicrometerMetricsExporter
recordDispatchLatencyMs(long) - Method in interface io.outbox.spi.MetricsExporter: Records end-to-end dispatch latency: from occurredAt to dispatch completion.
RecordingWriterHook - Class in io.outbox.testing: WriterHook that records all lifecycle invocations for test assertions.
RecordingWriterHook() - Constructor for class io.outbox.testing.RecordingWriterHook
recordListenerDurationMs(long) - Method in class io.outbox.micrometer.MicrometerMetricsExporter
recordListenerDurationMs(long) - Method in interface io.outbox.spi.MetricsExporter: Records the time spent executing the event listener only.
recordOldestLagMs(long) - Method in class io.outbox.micrometer.MicrometerMetricsExporter
recordOldestLagMs(long) - Method in class io.outbox.spi.MetricsExporter.Noop
recordOldestLagMs(long) - Method in interface io.outbox.spi.MetricsExporter: Records the lag (in milliseconds) of the oldest pending event.
recordQueueDepths(int, int) - Method in class io.outbox.micrometer.MicrometerMetricsExporter
recordQueueDepths(int, int) - Method in class io.outbox.spi.MetricsExporter.Noop
recordQueueDepths(int, int) - Method in interface io.outbox.spi.MetricsExporter: Records the current depth of both dispatch queues.
RecoverableException - Exception in io.outbox: Signals a transient failure that may succeed on retry.
RecoverableException(String) - Constructor for exception io.outbox.RecoverableException
RecoverableException(String, Throwable) - Constructor for exception io.outbox.RecoverableException
register(AggregateType, EventType, EventListener) - Method in class io.outbox.registry.DefaultListenerRegistry: Registers a listener for a type-safe (aggregateType, eventType) pair.
register(AggregateType, EventType, EventListener) - Method in class io.outbox.testing.OutboxTestSupport.Builder: Registers a listener for an aggregate-scoped event type.
register(AggregateType, String, EventListener) - Method in class io.outbox.registry.DefaultListenerRegistry: Registers a listener for a type-safe aggregateType and string eventType.
register(BoundEventListener) - Method in class io.outbox.registry.DefaultListenerRegistry: Registers a listener using its bound aggregate and event types.
register(EventType, EventListener) - Method in class io.outbox.registry.DefaultListenerRegistry: Registers a listener using AggregateType.GLOBAL as the aggregate type.
register(EventType, EventListener) - Method in class io.outbox.testing.OutboxTestSupport.Builder: Registers a listener for an event type (global aggregate).
register(String, EventListener) - Method in class io.outbox.registry.DefaultListenerRegistry: Registers a listener using AggregateType.GLOBAL as the aggregate type.
register(String, EventListener) - Method in class io.outbox.testing.OutboxTestSupport.Builder: Registers a listener for an event type (global aggregate).
register(String, String, EventListener) - Method in class io.outbox.registry.DefaultListenerRegistry: Registers a listener for a specific (aggregateType, eventType) pair.
register(String, String, EventListener) - Method in class io.outbox.testing.OutboxTestSupport.Builder: Registers a listener for an aggregate-scoped event type.
release(String) - Method in class io.outbox.dispatch.DefaultInFlightTracker
release(String) - Method in interface io.outbox.dispatch.InFlightTracker: Releases processing rights, allowing the event to be dispatched again.
replay(String) - Method in class io.outbox.dead.DeadEventManager: Replays a single DEAD event by resetting it to NEW status.
replayAll(String, String, int) - Method in class io.outbox.dead.DeadEventManager: Replays all DEAD events matching the given filters, processing in batches.
replayDead(Connection, String) - Method in class io.outbox.jdbc.store.AbstractJdbcOutboxStore
replayDead(Connection, String) - Method in interface io.outbox.spi.OutboxStore: Replays a DEAD event by resetting it to NEW status with zero attempts.
replayDead(Connection, String) - Method in class io.outbox.testing.InMemoryOutboxStore
resetDefault() - Static method in interface io.outbox.spi.JsonCodec: Resets the cached default instance, allowing re-discovery or re-set.
retention(Duration) - Method in class io.outbox.purge.OutboxPurgeScheduler.Builder: Sets the retention period.
Retry() - Constructor for class io.outbox.spring.boot.OutboxProperties.Retry
RETRY - Enum constant in enum class io.outbox.model.EventStatus: Failed but eligible for retry after a delay.
retryAfter() - Method in exception io.outbox.RetryAfterException: Returns the handler-requested retry delay.
retryAfter(Duration) - Static method in interface io.outbox.DispatchResult: Creates a DispatchResult.RetryAfter result requesting re-delivery after the given delay.
RetryAfter(Duration) - Constructor for record class io.outbox.DispatchResult.RetryAfter: Creates an instance of a RetryAfter record class.
RetryAfterException - Exception in io.outbox: Exception thrown by an EventListener to signal a failed attempt that should be retried after a handler-specified delay.
RetryAfterException(Duration) - Constructor for exception io.outbox.RetryAfterException: Creates a new instance with the specified retry delay.
RetryAfterException(Duration, String) - Constructor for exception io.outbox.RetryAfterException: Creates a new instance with the specified retry delay and message.
RetryAfterException(Duration, String, Throwable) - Constructor for exception io.outbox.RetryAfterException: Creates a new instance with the specified retry delay, message, and cause.
RetryAfterException(Duration, Throwable) - Constructor for exception io.outbox.RetryAfterException: Creates a new instance with the specified retry delay and cause.
retryPolicy(RetryPolicy) - Method in class io.outbox.dispatch.OutboxDispatcher.Builder: Sets the retry policy that computes delay between attempts on failure.
retryPolicy(RetryPolicy) - Method in class io.outbox.Outbox.MultiNodeBuilder: Sets the retry policy for computing delay between attempts.
retryPolicy(RetryPolicy) - Method in class io.outbox.Outbox.SingleNodeBuilder: Sets the retry policy for computing delay between attempts.
RetryPolicy - Interface in io.outbox.dispatch: Strategy for computing the delay before retrying a failed event dispatch.
rollback() - Method in class io.outbox.jdbc.tx.JdbcTransactionManager.Transaction
runAfterCommit() - Method in class io.outbox.testing.StubTxContext: Runs all registered afterCommit callbacks and clears the list.
runAfterRollback() - Method in class io.outbox.testing.StubTxContext: Runs all registered afterRollback callbacks and clears the list.
runOnce() - Method in class io.outbox.purge.OutboxPurgeScheduler: Executes a single purge cycle, deleting batches until fewer than batchSize rows are deleted.

S

seedEvents() - Method in class io.outbox.benchmark.OutboxPollerBenchmark
selectClaimed(Connection, String, Instant) - Method in class io.outbox.jdbc.store.AbstractJdbcOutboxStore: Selects rows previously claimed by the given owner at the given lock timestamp.
setActive(boolean) - Method in class io.outbox.testing.StubTxContext: Sets whether the transaction is active.
setBaseDelayMs(long) - Method in class io.outbox.spring.boot.OutboxProperties.Retry
setBatchSize(int) - Method in class io.outbox.spring.boot.OutboxProperties.Poller
setBatchSize(int) - Method in class io.outbox.spring.boot.OutboxProperties.Purge
setColdQueueCapacity(int) - Method in class io.outbox.spring.boot.OutboxProperties.Dispatcher
setDefault(JsonCodec) - Static method in interface io.outbox.spi.JsonCodec: Sets the default implementation programmatically, overriding SPI discovery.
setDrainTimeoutMs(long) - Method in class io.outbox.spring.boot.OutboxProperties.Dispatcher
setEnabled(boolean) - Method in class io.outbox.spring.boot.OutboxProperties.ClaimLocking
setEnabled(boolean) - Method in class io.outbox.spring.boot.OutboxProperties.Metrics
setEnabled(boolean) - Method in class io.outbox.spring.boot.OutboxProperties.Purge
setHotQueueCapacity(int) - Method in class io.outbox.spring.boot.OutboxProperties.Dispatcher
setIntervalMs(long) - Method in class io.outbox.spring.boot.OutboxProperties.Poller
setIntervalSeconds(long) - Method in class io.outbox.spring.boot.OutboxProperties.Purge
setLockTimeout(Duration) - Method in class io.outbox.spring.boot.OutboxProperties.ClaimLocking
setMaxAttempts(int) - Method in class io.outbox.spring.boot.OutboxProperties.Dispatcher
setMaxDelayMs(long) - Method in class io.outbox.spring.boot.OutboxProperties.Retry
setMode(OutboxProperties.Mode) - Method in class io.outbox.spring.boot.OutboxProperties
setNamePrefix(String) - Method in class io.outbox.spring.boot.OutboxProperties.Metrics
setOwnerId(String) - Method in class io.outbox.spring.boot.OutboxProperties.ClaimLocking
setRetention(Duration) - Method in class io.outbox.spring.boot.OutboxProperties.Purge
setSkipRecentMs(long) - Method in class io.outbox.spring.boot.OutboxProperties.Poller
setTableName(String) - Method in class io.outbox.spring.boot.OutboxProperties
setup() - Method in class io.outbox.benchmark.OutboxDispatchBenchmark
setup() - Method in class io.outbox.benchmark.OutboxPollerBenchmark
setup() - Method in class io.outbox.benchmark.OutboxWriteBenchmark
setupInvocationMutex - Variable in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_jmhType_B2
setupInvocationMutex - Variable in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_jmhType_B2
setupInvocationMutex - Variable in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_jmhType_B2
setupInvocationMutexUpdater - Static variable in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_jmhType_B2
setupInvocationMutexUpdater - Static variable in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_jmhType_B2
setupInvocationMutexUpdater - Static variable in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_jmhType_B2
setupIterationMutex - Variable in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_jmhType_B2
setupIterationMutex - Variable in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_jmhType_B2
setupIterationMutex - Variable in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_jmhType_B2
setupIterationMutexUpdater - Static variable in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_jmhType_B2
setupIterationMutexUpdater - Static variable in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_jmhType_B2
setupIterationMutexUpdater - Static variable in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_jmhType_B2
setupTrialMutex - Variable in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_jmhType_B2
setupTrialMutex - Variable in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_jmhType_B2
setupTrialMutex - Variable in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_jmhType_B2
setupTrialMutexUpdater - Static variable in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_jmhType_B2
setupTrialMutexUpdater - Static variable in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_jmhType_B2
setupTrialMutexUpdater - Static variable in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_jmhType_B2
setWorkerCount(int) - Method in class io.outbox.spring.boot.OutboxProperties.Dispatcher
SINGLE_NODE - Enum constant in enum class io.outbox.spring.boot.OutboxProperties.Mode
singleNode() - Static method in class io.outbox.Outbox: Creates a builder for single-node deployments with hot path + poller fallback.
size() - Method in class io.outbox.testing.InMemoryOutboxStore: Returns the total number of stored events.
skipRecent(Duration) - Method in class io.outbox.Outbox.AbstractBuilder: Sets a grace period to skip recently created events during polling.
skipRecent(Duration) - Method in class io.outbox.Outbox.WriterOnlyBuilder
skipRecent(Duration) - Method in class io.outbox.poller.OutboxPoller.Builder: Sets a grace period to skip recently created events during polling.
source() - Method in record class io.outbox.dispatch.QueuedEvent: Returns the value of the source record component.
SpringTxContext - Class in io.outbox.spring: TxContext implementation that bridges to Spring's transaction infrastructure via TransactionSynchronizationManager.
SpringTxContext(DataSource) - Constructor for class io.outbox.spring.SpringTxContext
start() - Method in class io.outbox.Outbox: Starts the poller.
start() - Method in class io.outbox.poller.OutboxPoller: Starts the scheduled polling loop.
start() - Method in class io.outbox.purge.OutboxPurgeScheduler: Starts the scheduled purge loop.
start() - Method in class io.outbox.spring.boot.OutboxLifecycle
statusOf(String) - Method in class io.outbox.testing.InMemoryOutboxStore: Returns the status of a specific event.
stop() - Method in class io.outbox.spring.boot.OutboxLifecycle
store() - Method in class io.outbox.testing.OutboxTestSupport: Returns the in-memory store for inspecting persisted events.
StringAggregateType - Record Class in io.outbox: A simple string-based aggregate type for dynamic scenarios.
StringAggregateType(String) - Constructor for record class io.outbox.StringAggregateType: Creates an instance of a StringAggregateType record class.
StringEventType - Record Class in io.outbox: A simple string-based event type for dynamic scenarios.
StringEventType(String) - Constructor for record class io.outbox.StringEventType: Creates an instance of a StringEventType record class.
StubTxContext - Class in io.outbox.testing: In-memory TxContext stub for unit testing outbox code without a database.
StubTxContext() - Constructor for class io.outbox.testing.StubTxContext: Creates a stub with an active transaction.
StubTxContext(boolean) - Constructor for class io.outbox.testing.StubTxContext: Creates a stub with the specified transaction state.

T

tableName() - Method in class io.outbox.jdbc.purge.AbstractJdbcAgeBasedPurger
tableName() - Method in class io.outbox.jdbc.purge.AbstractJdbcEventPurger
tableName() - Method in class io.outbox.jdbc.store.AbstractJdbcOutboxStore
TableNames - Class in io.outbox.jdbc: Shared table name validation for JDBC outbox components.
tearDown() - Method in class io.outbox.benchmark.OutboxDispatchBenchmark
tearDown() - Method in class io.outbox.benchmark.OutboxPollerBenchmark
tearDown() - Method in class io.outbox.benchmark.OutboxWriteBenchmark
tearInvocationMutex - Variable in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_jmhType_B2
tearInvocationMutex - Variable in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_jmhType_B2
tearInvocationMutex - Variable in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_jmhType_B2
tearInvocationMutexUpdater - Static variable in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_jmhType_B2
tearInvocationMutexUpdater - Static variable in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_jmhType_B2
tearInvocationMutexUpdater - Static variable in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_jmhType_B2
tearIterationMutex - Variable in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_jmhType_B2
tearIterationMutex - Variable in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_jmhType_B2
tearIterationMutex - Variable in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_jmhType_B2
tearIterationMutexUpdater - Static variable in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_jmhType_B2
tearIterationMutexUpdater - Static variable in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_jmhType_B2
tearIterationMutexUpdater - Static variable in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_jmhType_B2
tearTrialMutex - Variable in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_jmhType_B2
tearTrialMutex - Variable in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_jmhType_B2
tearTrialMutex - Variable in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_jmhType_B2
tearTrialMutexUpdater - Static variable in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_jmhType_B2
tearTrialMutexUpdater - Static variable in class io.outbox.benchmark.jmh_generated.OutboxPollerBenchmark_jmhType_B2
tearTrialMutexUpdater - Static variable in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_jmhType_B2
tenantId() - Method in class io.outbox.EventEnvelope
tenantId() - Method in record class io.outbox.model.OutboxEvent: Returns the value of the tenantId record component.
tenantId(String) - Method in class io.outbox.EventEnvelope.Builder: Sets the tenant identifier for multi-tenant systems.
TERMINAL_STATUS_IN - Static variable in class io.outbox.jdbc.purge.AbstractJdbcEventPurger
TERMINAL_STATUS_IN - Static variable in class io.outbox.jdbc.store.AbstractJdbcOutboxStore
ThreadLocalTxContext - Class in io.outbox.jdbc.tx: TxContext implementation that stores transaction state in a ThreadLocal.
ThreadLocalTxContext() - Constructor for class io.outbox.jdbc.tx.ThreadLocalTxContext
toJson(Object) - Method in class io.outbox.gson.GsonJsonCodec
toJson(Object) - Method in interface io.outbox.spi.JsonCodec: Serializes an object to a JSON string.
toJson(Object) - Method in class io.outbox.spring.boot.JacksonJsonCodec
toString() - Method in record class io.outbox.dispatch.QueuedEvent: Returns a string representation of this record class.
toString() - Method in record class io.outbox.DispatchResult.Dead: Returns a string representation of this record class.
toString() - Method in record class io.outbox.DispatchResult.Done: Returns a string representation of this record class.
toString() - Method in record class io.outbox.DispatchResult.RetryAfter: Returns a string representation of this record class.
toString() - Method in class io.outbox.EventEnvelope
toString() - Method in record class io.outbox.model.OutboxEvent: Returns a string representation of this record class.
toString() - Method in record class io.outbox.StringAggregateType: Returns a string representation of this record class.
toString() - Method in record class io.outbox.StringEventType: Returns a string representation of this record class.
truncate() - Method in class io.outbox.benchmark.OutboxDispatchBenchmark
truncate() - Method in class io.outbox.benchmark.OutboxWriteBenchmark
tryAcquire(String) - Method in class io.outbox.dispatch.DefaultInFlightTracker
tryAcquire(String) - Method in interface io.outbox.dispatch.InFlightTracker: Attempts to acquire exclusive processing rights for the given event.
txContext() - Method in class io.outbox.testing.OutboxTestSupport: Returns the stub transaction context for simulating commits/rollbacks.
txContext(TxContext) - Method in class io.outbox.Outbox.AbstractBuilder: Sets the transaction context for managing transaction lifecycle.
txContext(DataSource) - Method in class io.outbox.demo.spring.OutboxConfiguration
txContext(DataSource) - Method in class io.outbox.spring.boot.OutboxAutoConfiguration
TxContext - Interface in io.outbox.spi: Abstracts the transaction lifecycle so outbox operations can participate in the caller's transaction without depending on a specific transaction manager.

U

UnrecoverableException - Exception in io.outbox: Signals a deterministic failure that will never succeed on retry.
UnrecoverableException(String) - Constructor for exception io.outbox.UnrecoverableException
UnrecoverableException(String, Throwable) - Constructor for exception io.outbox.UnrecoverableException
UnroutableEventException - Exception in io.outbox.dispatch: Thrown when no listener is registered for an event's (aggregateType, eventType) combination.
UnroutableEventException(String) - Constructor for exception io.outbox.dispatch.UnroutableEventException
update(Connection, String, Object...) - Static method in class io.outbox.jdbc.JdbcTemplate: Execute UPDATE, return rows affected.
updateReturning(Connection, String, JdbcTemplate.RowMapper<T>, Object...) - Static method in class io.outbox.jdbc.JdbcTemplate: Execute UPDATE ...
UserCreatedListener - Class in io.outbox.demo.starter
UserCreatedListener() - Constructor for class io.outbox.demo.starter.UserCreatedListener

V

validate(String) - Static method in class io.outbox.jdbc.TableNames
valueOf(String) - Static method in enum class io.outbox.dispatch.QueuedEvent.Source: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.outbox.model.EventStatus: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.outbox.spring.boot.OutboxProperties.Mode: Returns the enum constant of this class with the specified name.
values() - Static method in enum class io.outbox.dispatch.QueuedEvent.Source: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.outbox.model.EventStatus: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.outbox.spring.boot.OutboxProperties.Mode: Returns an array containing the constants of this enum class, in the order they are declared.

W

workerCount(int) - Method in class io.outbox.dispatch.OutboxDispatcher.Builder: Sets the number of worker threads that drain and dispatch events.
workerCount(int) - Method in class io.outbox.Outbox.MultiNodeBuilder: Sets the number of dispatcher worker threads.
workerCount(int) - Method in class io.outbox.Outbox.SingleNodeBuilder: Sets the number of dispatcher worker threads.
write(EventEnvelope) - Method in class io.outbox.DefaultOutboxWriter
write(EventEnvelope) - Method in interface io.outbox.OutboxWriter: Writes a single event to the outbox within the current transaction.
write(EventType, String) - Method in class io.outbox.DefaultOutboxWriter
write(EventType, String) - Method in interface io.outbox.OutboxWriter: Convenience method to write a JSON event with a type-safe event type.
write(String, String) - Method in class io.outbox.DefaultOutboxWriter
write(String, String) - Method in interface io.outbox.OutboxWriter: Convenience method to write a JSON event with a string event type.
writeAll(List<EventEnvelope>) - Method in class io.outbox.DefaultOutboxWriter
writeAll(List<EventEnvelope>) - Method in interface io.outbox.OutboxWriter: Writes multiple events to the outbox within the current transaction.
writeAndDispatch() - Method in class io.outbox.benchmark.OutboxDispatchBenchmark
writeAndDispatch_AverageTime(InfraControl, ThreadParams) - Method in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_writeAndDispatch_jmhTest
writeAndDispatch_avgt_jmhStub(InfraControl, RawResults, BenchmarkParams, IterationParams, ThreadParams, Blackhole, Control, int, OutboxDispatchBenchmark_jmhType) - Static method in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_writeAndDispatch_jmhTest
writeAndDispatch_sample_jmhStub(InfraControl, RawResults, BenchmarkParams, IterationParams, ThreadParams, Blackhole, Control, int, SampleBuffer, int, long, int, OutboxDispatchBenchmark_jmhType) - Static method in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_writeAndDispatch_jmhTest
writeAndDispatch_SampleTime(InfraControl, ThreadParams) - Method in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_writeAndDispatch_jmhTest
writeAndDispatch_SingleShotTime(InfraControl, ThreadParams) - Method in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_writeAndDispatch_jmhTest
writeAndDispatch_ss_jmhStub(InfraControl, RawResults, BenchmarkParams, IterationParams, ThreadParams, Blackhole, Control, int, int, OutboxDispatchBenchmark_jmhType) - Static method in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_writeAndDispatch_jmhTest
writeAndDispatch_Throughput(InfraControl, ThreadParams) - Method in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_writeAndDispatch_jmhTest
writeAndDispatch_thrpt_jmhStub(InfraControl, RawResults, BenchmarkParams, IterationParams, ThreadParams, Blackhole, Control, int, OutboxDispatchBenchmark_jmhType) - Static method in class io.outbox.benchmark.jmh_generated.OutboxDispatchBenchmark_writeAndDispatch_jmhTest
writeEvent() - Method in class io.outbox.benchmark.OutboxWriteBenchmark
writeEvent_AverageTime(InfraControl, ThreadParams) - Method in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_writeEvent_jmhTest
writeEvent_avgt_jmhStub(InfraControl, RawResults, BenchmarkParams, IterationParams, ThreadParams, Blackhole, Control, int, OutboxWriteBenchmark_jmhType) - Static method in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_writeEvent_jmhTest
writeEvent_sample_jmhStub(InfraControl, RawResults, BenchmarkParams, IterationParams, ThreadParams, Blackhole, Control, int, SampleBuffer, int, long, int, OutboxWriteBenchmark_jmhType) - Static method in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_writeEvent_jmhTest
writeEvent_SampleTime(InfraControl, ThreadParams) - Method in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_writeEvent_jmhTest
writeEvent_SingleShotTime(InfraControl, ThreadParams) - Method in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_writeEvent_jmhTest
writeEvent_ss_jmhStub(InfraControl, RawResults, BenchmarkParams, IterationParams, ThreadParams, Blackhole, Control, int, int, OutboxWriteBenchmark_jmhType) - Static method in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_writeEvent_jmhTest
writeEvent_Throughput(InfraControl, ThreadParams) - Method in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_writeEvent_jmhTest
writeEvent_thrpt_jmhStub(InfraControl, RawResults, BenchmarkParams, IterationParams, ThreadParams, Blackhole, Control, int, OutboxWriteBenchmark_jmhType) - Static method in class io.outbox.benchmark.jmh_generated.OutboxWriteBenchmark_writeEvent_jmhTest
writer() - Method in class io.outbox.Outbox: Returns the writer for persisting events within transactions.
writer() - Method in class io.outbox.testing.OutboxTestSupport: Returns the outbox writer for writing events.
WRITER_ONLY - Enum constant in enum class io.outbox.spring.boot.OutboxProperties.Mode
writerHook(WriterHook) - Method in class io.outbox.testing.OutboxTestSupport.Builder: Sets a custom writer hook.
WriterHook - Interface in io.outbox: Lifecycle hook for OutboxWriter batch writes, replacing the former AfterCommitHook with richer before/after semantics.
writerOnly() - Static method in class io.outbox.Outbox: Creates a builder for writer-only (CDC) mode: no dispatcher or poller.

A B C D E F G H I J L M N O P Q R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form