Index (outbox-parent 0.1.0-SNAPSHOT API)

A B C D E 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

AbstractJdbcEventStore - Class in outbox.jdbc: Base JDBC event store with standard SQL implementations.
AbstractJdbcEventStore() - Constructor for class outbox.jdbc.AbstractJdbcEventStore
AbstractJdbcEventStore(String) - Constructor for class outbox.jdbc.AbstractJdbcEventStore
accept(EventEnvelope) - Method in interface outbox.dispatch.EventInterceptor.BeforeHook
accept(EventEnvelope, Exception) - Method in interface outbox.dispatch.EventInterceptor.AfterHook
after(EventInterceptor.AfterHook) - Static method in interface outbox.dispatch.EventInterceptor: Creates an interceptor with only an afterDispatch hook.
afterCommit(Runnable) - Method in class outbox.jdbc.ThreadLocalTxContext
afterCommit(Runnable) - Method in interface outbox.spi.TxContext
afterCommit(Runnable) - Method in class outbox.spring.SpringTxContext
AfterCommitHook - Interface in outbox
afterDispatch(EventEnvelope, Exception) - Method in interface outbox.dispatch.EventInterceptor: Called after listener invocation (or after beforeDispatch failure).
afterRollback(Runnable) - Method in class outbox.jdbc.ThreadLocalTxContext
afterRollback(Runnable) - Method in interface outbox.spi.TxContext
afterRollback(Runnable) - Method in class outbox.spring.SpringTxContext
aggregateId() - Method in class outbox.EventEnvelope
aggregateId() - Method in record class outbox.model.OutboxEvent: Returns the value of the aggregateId record component.
aggregateId(String) - Method in class outbox.EventEnvelope.Builder
aggregateType() - Method in class outbox.EventEnvelope
aggregateType() - Method in record class outbox.model.OutboxEvent: Returns the value of the aggregateType record component.
aggregateType(String) - Method in class outbox.EventEnvelope.Builder
aggregateType(AggregateType) - Method in class outbox.EventEnvelope.Builder
AggregateType - Interface in outbox: Represents an aggregate type identifier.
all() - Static method in class outbox.jdbc.JdbcEventStores: Returns all registered event stores.
Application - Class in outbox.demo.spring: Spring Boot demo for outbox framework.
Application() - Constructor for class outbox.demo.spring.Application
attempts() - Method in record class outbox.dispatch.QueuedEvent: Returns the value of the attempts record component.
attempts() - Method in record class outbox.model.OutboxEvent: Returns the value of the attempts record component.

B

batchSize(int) - Method in class outbox.poller.OutboxPoller.Builder
before(EventInterceptor.BeforeHook) - Static method in interface outbox.dispatch.EventInterceptor: Creates an interceptor with only a beforeDispatch hook.
beforeDispatch(EventEnvelope) - Method in interface outbox.dispatch.EventInterceptor: Called before the event listener is invoked.
begin() - Method in class outbox.jdbc.JdbcTransactionManager
build() - Method in class outbox.dispatch.OutboxDispatcher.Builder
build() - Method in class outbox.EventEnvelope.Builder
build() - Method in class outbox.poller.OutboxPoller.Builder
builder() - Static method in class outbox.dispatch.OutboxDispatcher
builder() - Static method in class outbox.poller.OutboxPoller
builder(String) - Static method in class outbox.EventEnvelope: Creates a builder with a string event type.
builder(EventType) - Static method in class outbox.EventEnvelope: Creates a builder with a type-safe event type.

C

claimPending(Connection, String, Instant, Instant, Duration, int) - Method in class outbox.jdbc.AbstractJdbcEventStore
claimPending(Connection, String, Instant, Instant, Duration, int) - Method in class outbox.jdbc.MySqlEventStore
claimPending(Connection, String, Instant, Instant, Duration, int) - Method in class outbox.jdbc.PostgresEventStore
claimPending(Connection, String, Instant, Instant, Duration, int) - Method in interface outbox.spi.EventStore: Claim and return pending events with locking.
close() - Method in class outbox.dispatch.OutboxDispatcher
close() - Method in class outbox.jdbc.JdbcTransactionManager.Transaction
close() - Method in class outbox.poller.OutboxPoller
code() - Method in enum class outbox.model.EventStatus
COLD - Enum constant in enum class outbox.dispatch.QueuedEvent.Source
coldQueueCapacity(int) - Method in class outbox.dispatch.OutboxDispatcher.Builder
commit() - Method in class outbox.jdbc.JdbcTransactionManager.Transaction
computeDelayMs(int) - Method in class outbox.dispatch.ExponentialBackoffRetryPolicy
computeDelayMs(int) - Method in interface outbox.dispatch.RetryPolicy
connectionProvider(DataSource) - Method in class outbox.demo.spring.OutboxConfiguration
connectionProvider(ConnectionProvider) - Method in class outbox.dispatch.OutboxDispatcher.Builder
connectionProvider(ConnectionProvider) - Method in class outbox.poller.OutboxPoller.Builder
ConnectionProvider - Interface in outbox.spi
createdAt() - Method in record class outbox.model.OutboxEvent: Returns the value of the createdAt record component.
currentConnection() - Method in class outbox.jdbc.ThreadLocalTxContext
currentConnection() - Method in interface outbox.spi.TxContext
currentConnection() - Method in class outbox.spring.SpringTxContext

D

DaemonThreadFactory - Class in outbox.util: Thread factory that creates named daemon threads.
DaemonThreadFactory(String) - Constructor for class outbox.util.DaemonThreadFactory
DataSourceConnectionProvider - Class in outbox.jdbc
DataSourceConnectionProvider(DataSource) - Constructor for class outbox.jdbc.DataSourceConnectionProvider
DEAD - Enum constant in enum class outbox.model.EventStatus
DEFAULT_TABLE - Static variable in class outbox.jdbc.AbstractJdbcEventStore
DefaultInFlightTracker - Class in outbox.dispatch
DefaultInFlightTracker() - Constructor for class outbox.dispatch.DefaultInFlightTracker
DefaultInFlightTracker(long) - Constructor for class outbox.dispatch.DefaultInFlightTracker
DefaultListenerRegistry - Class in outbox.registry: Thread-safe registry mapping (aggregateType, eventType) pairs to listeners.
DefaultListenerRegistry() - Constructor for class outbox.registry.DefaultListenerRegistry
detect(String) - Static method in class outbox.jdbc.JdbcEventStores: Auto-detects event store from a JDBC URL.
detect(DataSource) - Static method in class outbox.jdbc.JdbcEventStores: Auto-detects event store from a DataSource.
dispatcher(DataSourceConnectionProvider, AbstractJdbcEventStore, ListenerRegistry) - Method in class outbox.demo.spring.OutboxConfiguration
DispatcherCommitHook - Class in outbox.dispatch
DispatcherCommitHook(OutboxDispatcher) - Constructor for class outbox.dispatch.DispatcherCommitHook
DispatcherCommitHook(OutboxDispatcher, MetricsExporter) - Constructor for class outbox.dispatch.DispatcherCommitHook
DispatcherPollerHandler - Class in outbox.dispatch
DispatcherPollerHandler(OutboxDispatcher) - Constructor for class outbox.dispatch.DispatcherPollerHandler
DONE - Enum constant in enum class outbox.model.EventStatus
drainTimeoutMs(long) - Method in class outbox.dispatch.OutboxDispatcher.Builder

E

enqueueCold(QueuedEvent) - Method in class outbox.dispatch.OutboxDispatcher
enqueueHot(QueuedEvent) - Method in class outbox.dispatch.OutboxDispatcher
envelope() - Method in record class outbox.dispatch.QueuedEvent: Returns the value of the envelope record component.
equals(Object) - Method in record class outbox.dispatch.QueuedEvent: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class outbox.model.OutboxEvent: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class outbox.StringAggregateType: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class outbox.StringEventType: Indicates whether some other object is "equal to" this one.
EVENT_ROW_MAPPER - Static variable in class outbox.jdbc.AbstractJdbcEventStore
EventController - Class in outbox.demo.spring
EventController(OutboxWriter, JdbcTemplate) - Constructor for class outbox.demo.spring.EventController
EventEnvelope - Class in outbox
EventEnvelope.Builder - Class in outbox
eventId() - Method in class outbox.EventEnvelope
eventId() - Method in record class outbox.model.OutboxEvent: Returns the value of the eventId record component.
eventId(String) - Method in class outbox.EventEnvelope.Builder
EventInterceptor - Interface in outbox.dispatch: Cross-cutting hook for observing or modifying event dispatch.
EventInterceptor.AfterHook - Interface in outbox.dispatch
EventInterceptor.BeforeHook - Interface in outbox.dispatch
EventListener - Interface in outbox: Listener that reacts to outbox events.
EventStatus - Enum Class in outbox.model
eventStore(DataSource) - Method in class outbox.demo.spring.OutboxConfiguration
eventStore(EventStore) - Method in class outbox.dispatch.OutboxDispatcher.Builder
eventStore(EventStore) - Method in class outbox.poller.OutboxPoller.Builder
EventStore - Interface in outbox.spi
EventStoreException - Exception in outbox.jdbc
EventStoreException(String, Throwable) - Constructor for exception outbox.jdbc.EventStoreException
eventType() - Method in class outbox.EventEnvelope
eventType() - Method in record class outbox.model.OutboxEvent: Returns the value of the eventType record component.
EventType - Interface in outbox: Represents an event type identifier.
ExponentialBackoffRetryPolicy - Class in outbox.dispatch
ExponentialBackoffRetryPolicy(long, long) - Constructor for class outbox.dispatch.ExponentialBackoffRetryPolicy

G

get(String) - Static method in class outbox.jdbc.JdbcEventStores: Gets an event store by name.
getConnection() - Method in class outbox.jdbc.DataSourceConnectionProvider
getConnection() - Method in interface outbox.spi.ConnectionProvider
GLOBAL - Static variable in interface outbox.AggregateType: Global aggregate type used when no specific aggregate type is set.

H

H2EventStore - Class in outbox.jdbc: H2 event store.
H2EventStore() - Constructor for class outbox.jdbc.H2EventStore
H2EventStore(String) - Constructor for class outbox.jdbc.H2EventStore
handle(EventEnvelope, int) - Method in class outbox.dispatch.DispatcherPollerHandler
handle(EventEnvelope, int) - Method in interface outbox.poller.OutboxPollerHandler
handler(OutboxPollerHandler) - Method in class outbox.poller.OutboxPoller.Builder
hasCapacity() - Method in class outbox.dispatch.DispatcherPollerHandler
hasCapacity() - Method in interface outbox.poller.OutboxPollerHandler
hasColdQueueCapacity() - Method in class outbox.dispatch.OutboxDispatcher
hashCode() - Method in record class outbox.dispatch.QueuedEvent: Returns a hash code value for this object.
hashCode() - Method in record class outbox.model.OutboxEvent: Returns a hash code value for this object.
hashCode() - Method in record class outbox.StringAggregateType: Returns a hash code value for this object.
hashCode() - Method in record class outbox.StringEventType: Returns a hash code value for this object.
headers() - Method in class outbox.EventEnvelope
headers(Map<String, String>) - Method in class outbox.EventEnvelope.Builder
headersJson() - Method in record class outbox.model.OutboxEvent: Returns the value of the headersJson record component.
HOT - Enum constant in enum class outbox.dispatch.QueuedEvent.Source
hotQueueCapacity(int) - Method in class outbox.dispatch.OutboxDispatcher.Builder

I

incrementColdEnqueued() - Method in interface outbox.spi.MetricsExporter
incrementColdEnqueued() - Method in class outbox.spi.MetricsExporter.Noop
incrementDispatchDead() - Method in interface outbox.spi.MetricsExporter
incrementDispatchDead() - Method in class outbox.spi.MetricsExporter.Noop
incrementDispatchFailure() - Method in interface outbox.spi.MetricsExporter
incrementDispatchFailure() - Method in class outbox.spi.MetricsExporter.Noop
incrementDispatchSuccess() - Method in interface outbox.spi.MetricsExporter
incrementDispatchSuccess() - Method in class outbox.spi.MetricsExporter.Noop
incrementHotDropped() - Method in interface outbox.spi.MetricsExporter
incrementHotDropped() - Method in class outbox.spi.MetricsExporter.Noop
incrementHotEnqueued() - Method in interface outbox.spi.MetricsExporter
incrementHotEnqueued() - Method in class outbox.spi.MetricsExporter.Noop
inFlightTracker(InFlightTracker) - Method in class outbox.dispatch.OutboxDispatcher.Builder
InFlightTracker - Interface in outbox.dispatch
insertNew(Connection, EventEnvelope) - Method in class outbox.jdbc.AbstractJdbcEventStore
insertNew(Connection, EventEnvelope) - Method in interface outbox.spi.EventStore
interceptor(EventInterceptor) - Method in class outbox.dispatch.OutboxDispatcher.Builder
interceptors(List<EventInterceptor>) - Method in class outbox.dispatch.OutboxDispatcher.Builder
intervalMs(long) - Method in class outbox.poller.OutboxPoller.Builder
isTransactionActive() - Method in class outbox.jdbc.ThreadLocalTxContext
isTransactionActive() - Method in interface outbox.spi.TxContext
isTransactionActive() - Method in class outbox.spring.SpringTxContext

J

JdbcEventStores - Class in outbox.jdbc: Registry for JDBC event stores with auto-detection support.
JdbcTemplate - Class in outbox.jdbc: Lightweight JDBC helper to reduce boilerplate in event store implementations.
JdbcTemplate.RowMapper<T> - Interface in outbox.jdbc
JdbcTransactionManager - Class in outbox.jdbc
JdbcTransactionManager(ConnectionProvider, ThreadLocalTxContext) - Constructor for class outbox.jdbc.JdbcTransactionManager
JdbcTransactionManager.Transaction - Class in outbox.jdbc
jdbcUrlPrefixes() - Method in class outbox.jdbc.AbstractJdbcEventStore: JDBC URL prefixes this event store handles (e.g., "jdbc:mysql:", "jdbc:tidb:").
jdbcUrlPrefixes() - Method in class outbox.jdbc.H2EventStore
jdbcUrlPrefixes() - Method in class outbox.jdbc.MySqlEventStore
jdbcUrlPrefixes() - Method in class outbox.jdbc.PostgresEventStore
JsonCodec - Class in outbox.util

L

listenerFor(String, String) - Method in class outbox.registry.DefaultListenerRegistry
listenerFor(String, String) - Method in interface outbox.registry.ListenerRegistry: Returns the single listener for the given (aggregateType, eventType), or null if none registered.
listenerRegistry() - Method in class outbox.demo.spring.OutboxConfiguration
listenerRegistry(ListenerRegistry) - Method in class outbox.dispatch.OutboxDispatcher.Builder
ListenerRegistry - Interface in outbox.registry: Registry for looking up event listeners by (aggregateType, eventType).
listEvents() - Method in class outbox.demo.spring.EventController
lockTimeout(Duration) - Method in class outbox.poller.OutboxPoller.Builder

M

main(String[]) - Static method in class outbox.demo.multids.MultiDatasourceDemo
main(String[]) - Static method in class outbox.demo.OutboxDemo
main(String[]) - Static method in class outbox.demo.spring.Application
map(ResultSet) - Method in interface outbox.jdbc.JdbcTemplate.RowMapper
markDead(Connection, String, String) - Method in class outbox.jdbc.AbstractJdbcEventStore
markDead(Connection, String, String) - Method in interface outbox.spi.EventStore
markDone(Connection, String) - Method in class outbox.jdbc.AbstractJdbcEventStore
markDone(Connection, String) - Method in interface outbox.spi.EventStore
markRetry(Connection, String, Instant, String) - Method in class outbox.jdbc.AbstractJdbcEventStore
markRetry(Connection, String, Instant, String) - Method in interface outbox.spi.EventStore
MAX_PAYLOAD_BYTES - Static variable in class outbox.EventEnvelope
maxAttempts(int) - Method in class outbox.dispatch.OutboxDispatcher.Builder
metrics(MetricsExporter) - Method in class outbox.dispatch.OutboxDispatcher.Builder
metrics(MetricsExporter) - Method in class outbox.poller.OutboxPoller.Builder
MetricsExporter - Interface in outbox.spi
MetricsExporter.Noop - Class in outbox.spi
MultiDatasourceDemo - Class in 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 outbox.demo.multids.MultiDatasourceDemo
MySqlEventStore - Class in outbox.jdbc: MySQL event store.
MySqlEventStore() - Constructor for class outbox.jdbc.MySqlEventStore
MySqlEventStore(String) - Constructor for class outbox.jdbc.MySqlEventStore

N

name() - Method in interface outbox.AggregateType: Returns the string representation of this aggregate type.
name() - Method in interface outbox.EventType: Returns the string representation of this event type.
name() - Method in class outbox.jdbc.AbstractJdbcEventStore: Unique identifier for this event store (e.g., "mysql", "postgresql", "h2").
name() - Method in class outbox.jdbc.H2EventStore
name() - Method in class outbox.jdbc.MySqlEventStore
name() - Method in class outbox.jdbc.PostgresEventStore
name() - Method in record class outbox.StringAggregateType: Returns the value of the name record component.
name() - Method in record class outbox.StringEventType: Returns the value of the name record component.
NEW - Enum constant in enum class outbox.model.EventStatus
newThread(Runnable) - Method in class outbox.util.DaemonThreadFactory
Noop() - Constructor for class outbox.spi.MetricsExporter.Noop
NOOP - Static variable in interface outbox.AfterCommitHook
NOOP - Static variable in interface outbox.spi.MetricsExporter

O

occurredAt() - Method in class outbox.EventEnvelope
occurredAt(Instant) - Method in class outbox.EventEnvelope.Builder
of(String) - Static method in record class outbox.StringAggregateType: Creates an aggregate type from a string.
of(String) - Static method in record class outbox.StringEventType: Creates an event type from a string.
ofJson(String, String) - Static method in class outbox.EventEnvelope: Creates an envelope with a string event type and JSON payload.
ofJson(EventType, String) - Static method in class outbox.EventEnvelope: Creates an envelope with a type-safe event type and JSON payload.
onCommit(EventEnvelope) - Method in interface outbox.AfterCommitHook
onCommit(EventEnvelope) - Method in class outbox.dispatch.DispatcherCommitHook
onEvent(EventEnvelope) - Method in interface outbox.EventListener: Processes an outbox event.
outbox - package outbox
outbox.demo - package outbox.demo
outbox.demo.multids - package outbox.demo.multids
outbox.demo.spring - package outbox.demo.spring
outbox.dispatch - package outbox.dispatch
outbox.jdbc - package outbox.jdbc
outbox.model - package outbox.model
outbox.poller - package outbox.poller
outbox.registry - package outbox.registry
outbox.spi - package outbox.spi
outbox.spring - package outbox.spring
outbox.util - package outbox.util
OutboxConfiguration - Class in outbox.demo.spring
OutboxConfiguration() - Constructor for class outbox.demo.spring.OutboxConfiguration
OutboxDemo - Class in outbox.demo: Simple demo showing outbox framework usage without Spring.
OutboxDemo() - Constructor for class outbox.demo.OutboxDemo
OutboxDispatcher - Class in outbox.dispatch
OutboxDispatcher.Builder - Class in outbox.dispatch
OutboxEvent - Record Class in outbox.model
OutboxEvent(String, String, String, String, String, String, String, int, Instant) - Constructor for record class outbox.model.OutboxEvent: Creates an instance of a OutboxEvent record class.
outboxPoller(DataSourceConnectionProvider, AbstractJdbcEventStore, OutboxDispatcher) - Method in class outbox.demo.spring.OutboxConfiguration
OutboxPoller - Class in outbox.poller
OutboxPoller.Builder - Class in outbox.poller
OutboxPollerHandler - Interface in outbox.poller
outboxWriter(TxContext, AbstractJdbcEventStore, OutboxDispatcher) - Method in class outbox.demo.spring.OutboxConfiguration
OutboxWriter - Class in outbox
OutboxWriter(TxContext, EventStore) - Constructor for class outbox.OutboxWriter
OutboxWriter(TxContext, EventStore, AfterCommitHook) - Constructor for class outbox.OutboxWriter
ownerId(String) - Method in class outbox.poller.OutboxPoller.Builder

P

parseObject(String) - Static method in class outbox.util.JsonCodec
payloadBytes() - Method in class outbox.EventEnvelope
payloadBytes(byte[]) - Method in class outbox.EventEnvelope.Builder
payloadJson() - Method in class outbox.EventEnvelope
payloadJson() - Method in record class outbox.model.OutboxEvent: Returns the value of the payloadJson record component.
payloadJson(String) - Method in class outbox.EventEnvelope.Builder
PENDING_STATUS_IN - Static variable in class outbox.jdbc.AbstractJdbcEventStore
poll() - Method in class outbox.poller.OutboxPoller
pollPending(Connection, Instant, Duration, int) - Method in class outbox.jdbc.AbstractJdbcEventStore
pollPending(Connection, Instant, Duration, int) - Method in interface outbox.spi.EventStore
PostgresEventStore - Class in outbox.jdbc: PostgreSQL event store.
PostgresEventStore() - Constructor for class outbox.jdbc.PostgresEventStore
PostgresEventStore(String) - Constructor for class outbox.jdbc.PostgresEventStore
publishOrderPlaced(String, double) - Method in class outbox.demo.spring.EventController
publishUserCreated(String) - Method in class outbox.demo.spring.EventController

Q

query(Connection, String, JdbcTemplate.RowMapper<T>, Object...) - Static method in class outbox.jdbc.JdbcTemplate: Execute SELECT, map rows.
QueuedEvent - Record Class in outbox.dispatch
QueuedEvent(EventEnvelope, QueuedEvent.Source, int) - Constructor for record class outbox.dispatch.QueuedEvent: Creates an instance of a QueuedEvent record class.
QueuedEvent.Source - Enum Class in outbox.dispatch

R

recentCutoff(Instant, Duration) - Method in class outbox.jdbc.AbstractJdbcEventStore
recordOldestLagMs(long) - Method in class outbox.spi.MetricsExporter.Noop
recordOldestLagMs(long) - Method in interface outbox.spi.MetricsExporter
recordQueueDepths(int, int) - Method in class outbox.spi.MetricsExporter.Noop
recordQueueDepths(int, int) - Method in interface outbox.spi.MetricsExporter
register(String, String, EventListener) - Method in class outbox.registry.DefaultListenerRegistry: Registers a listener for a specific (aggregateType, eventType) pair.
register(String, EventListener) - Method in class outbox.registry.DefaultListenerRegistry: Registers a listener using AggregateType.GLOBAL as the aggregate type.
register(AggregateType, String, EventListener) - Method in class outbox.registry.DefaultListenerRegistry: Registers a listener for a type-safe aggregateType and string eventType.
register(AggregateType, EventType, EventListener) - Method in class outbox.registry.DefaultListenerRegistry: Registers a listener for a type-safe (aggregateType, eventType) pair.
register(EventType, EventListener) - Method in class outbox.registry.DefaultListenerRegistry: Registers a listener using AggregateType.GLOBAL as the aggregate type.
release(String) - Method in class outbox.dispatch.DefaultInFlightTracker
release(String) - Method in interface outbox.dispatch.InFlightTracker
RETRY - Enum constant in enum class outbox.model.EventStatus
retryPolicy(RetryPolicy) - Method in class outbox.dispatch.OutboxDispatcher.Builder
RetryPolicy - Interface in outbox.dispatch
rollback() - Method in class outbox.jdbc.JdbcTransactionManager.Transaction

S

selectClaimed(Connection, String, Instant) - Method in class outbox.jdbc.AbstractJdbcEventStore: Selects rows previously claimed by the given owner at the given lock timestamp.
skipRecent(Duration) - Method in class outbox.poller.OutboxPoller.Builder
source() - Method in record class outbox.dispatch.QueuedEvent: Returns the value of the source record component.
SpringTxContext - Class in outbox.spring
SpringTxContext(DataSource) - Constructor for class outbox.spring.SpringTxContext
start() - Method in class outbox.poller.OutboxPoller
StringAggregateType - Record Class in outbox: A simple string-based aggregate type for dynamic scenarios.
StringAggregateType(String) - Constructor for record class outbox.StringAggregateType: Creates an instance of a StringAggregateType record class.
StringEventType - Record Class in outbox: A simple string-based event type for dynamic scenarios.
StringEventType(String) - Constructor for record class outbox.StringEventType: Creates an instance of a StringEventType record class.

T

tableName() - Method in class outbox.jdbc.AbstractJdbcEventStore
tenantId() - Method in class outbox.EventEnvelope
tenantId() - Method in record class outbox.model.OutboxEvent: Returns the value of the tenantId record component.
tenantId(String) - Method in class outbox.EventEnvelope.Builder
ThreadLocalTxContext - Class in outbox.jdbc
ThreadLocalTxContext() - Constructor for class outbox.jdbc.ThreadLocalTxContext
toJson(Map<String, String>) - Static method in class outbox.util.JsonCodec
toString() - Method in record class outbox.dispatch.QueuedEvent: Returns a string representation of this record class.
toString() - Method in class outbox.EventEnvelope
toString() - Method in record class outbox.model.OutboxEvent: Returns a string representation of this record class.
toString() - Method in record class outbox.StringAggregateType: Returns a string representation of this record class.
toString() - Method in record class outbox.StringEventType: Returns a string representation of this record class.
tryAcquire(String) - Method in class outbox.dispatch.DefaultInFlightTracker
tryAcquire(String) - Method in interface outbox.dispatch.InFlightTracker
txContext(DataSource) - Method in class outbox.demo.spring.OutboxConfiguration
TxContext - Interface in outbox.spi

U

UnroutableEventException - Exception in outbox.dispatch: Thrown when no listener is registered for an event's (aggregateType, eventType) combination.
UnroutableEventException(String) - Constructor for exception outbox.dispatch.UnroutableEventException
update(Connection, String, Object...) - Static method in class outbox.jdbc.JdbcTemplate: Execute UPDATE, return rows affected.
updateReturning(Connection, String, JdbcTemplate.RowMapper<T>, Object...) - Static method in class outbox.jdbc.JdbcTemplate: Execute UPDATE ...

V

valueOf(String) - Static method in enum class outbox.dispatch.QueuedEvent.Source: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class outbox.model.EventStatus: Returns the enum constant of this class with the specified name.
values() - Static method in enum class 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 outbox.model.EventStatus: Returns an array containing the constants of this enum class, in the order they are declared.

W

workerCount(int) - Method in class outbox.dispatch.OutboxDispatcher.Builder
write(String, String) - Method in class outbox.OutboxWriter
write(EventEnvelope) - Method in class outbox.OutboxWriter
write(EventType, String) - Method in class outbox.OutboxWriter
writeAll(List<EventEnvelope>) - Method in class outbox.OutboxWriter

A B C D E 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