Group: GitHub Bams22

Sort by:Popular▼

✓Popular✓Newest

Public API of event-outboxer: OutboxEventPublisher, EventHandler, FailureHandler chain, OutboxListener, domain value objects, and exception hierarchy.

Service Provider Interfaces for event-outboxer adapters: EventStore, WorkerRegistry, EntityLocker, EventSerializer, Clock, ConnectionSupplier. Also ships reusable abstract contract tests for adapters to implement.

In-memory implementation of EventStore, WorkerRegistry and EntityLocker. Intended for fast unit tests and for development setups where durability is not required.

Core engine of event-outboxer: OutboxEngine, Poller, HandlerDispatcher, InFlightRegistry, maintenance tasks (HeartbeatTask, OrphanRecoveryTask, WatchdogTask), EventHandlerResolver, and the default OutboxEventPublisher. ...

Jackson implementation of EventSerializer, plus JacksonObjectMapperFactory.defaults() for callers that do not supply their own ObjectMapper.

MetricsSnapshotCache backed by Redis/KeyDB. Shares a single cached OutboxMetricsSnapshot across pods so /actuator/health/outbox returns a consistent view on every replica.

EntityLocker backed by PostgreSQL pg_advisory_lock. Suitable for single-instance deployments and simple clustered setups.

EntityLocker backed by Redis/KeyDB. Uses SET NX PX + a Lua fencing-token unlock for safety under multi-instance deployments.

Implementation of OutboxListener that publishes counters, timers and gauges to a Micrometer MeterRegistry. Ready-made observability for users who already wire Micrometer.

PostgreSQL implementation of EventStore and WorkerRegistry with SELECT FOR UPDATE SKIP LOCKED claim semantics. Spring-free — uses the ConnectionSupplier SPI port so it works in both plain-Java and Spring setups.

Test helpers for applications using event-outboxer: SettableClock, ManualEngine, fluent EventAssertions, RecordingOutboxListener, and a JUnit 5 extension for deterministic tests.

Bill of Materials for event-outboxer. Import this BOM to pin consistent versions of all event-outboxer modules.

Embedded transactional outbox for Java 17+ / Spring Boot 3.5.6+ / PostgreSQL 15+ / Redis/keydb. Parent POM aggregating all modules.

Spring Boot 3.5 starter for event-outboxer. Provides autoconfiguration, @ConfigurationProperties binding, SmartLifecycle wiring, TransactionAwareDataSourceProxy, and Spring-aware ConnectionSupplier.