messaging/messaging-reliability-api/src/main/java/dev/caskeleton/messaging/reliability/OutboxLease.java:18:public record OutboxLease(OutboxRecord record, String owner, long token, Instant expiresAt) { messaging/messaging-reliability-api/src/main/java/dev/caskeleton/messaging/reliability/OutboxLease.java:20: public OutboxLease { messaging/messaging-reliability-api/src/main/java/dev/caskeleton/messaging/reliability/OutboxRepository.java:47: List claimBatch(String owner, int batchSize, Duration leaseDuration, Instant now); messaging/messaging-reliability-api/src/main/java/dev/caskeleton/messaging/reliability/OutboxRepository.java:58: List claimBatch( messaging/messaging-reliability-api/src/main/java/dev/caskeleton/messaging/reliability/OutboxRepository.java:74: OutboxTransitionResult markPublished(OutboxLease lease, Instant now); messaging/messaging-reliability-api/src/main/java/dev/caskeleton/messaging/reliability/OutboxRepository.java:88: OutboxTransitionResult markAmbiguous(OutboxLease lease, String failureCode, Instant now); messaging/messaging-reliability-api/src/main/java/dev/caskeleton/messaging/reliability/OutboxRepository.java:92: OutboxLease lease, String failureCode, Instant now, Instant nextAttemptAt); messaging/messaging-reliability-api/src/main/java/dev/caskeleton/messaging/reliability/OutboxRepository.java:100: OutboxTransitionResult markExhausted(OutboxLease lease, String reason, Instant now); messaging/messaging-reliability-api/src/main/java/dev/caskeleton/messaging/reliability/OutboxRepository.java:112: OutboxTransitionResult markFailed(OutboxLease lease, String failureCode, Instant now); messaging/messaging-reliability-api/src/main/java/dev/caskeleton/messaging/reliability/OutboxRepository.java:122: OutboxTransitionResult releaseLease(OutboxLease lease);