diff --git a/src/main/kotlin/no/iktdev/eventi/events/EventPollerImplementation.kt b/src/main/kotlin/no/iktdev/eventi/events/EventPollerImplementation.kt index 5ba9b9f..0b3c85b 100644 --- a/src/main/kotlin/no/iktdev/eventi/events/EventPollerImplementation.kt +++ b/src/main/kotlin/no/iktdev/eventi/events/EventPollerImplementation.kt @@ -60,8 +60,9 @@ abstract class EventPollerImplementation( dispatchQueue.dispatch(referenceId, events, dispatcher) } val maxPersistedAt = newPersisted.maxOf { it.persistedAt } - log.debug { "Updating lastSeenTime from $lastSeenTime to ${minOf(pollStartedAt, maxPersistedAt).plusNanos(1)}" } - lastSeenTime = minOf(pollStartedAt, maxPersistedAt).plusNanos(1) + val newCheckpointTime = minOf(pollStartedAt, maxPersistedAt) + log.debug { "Updating lastSeenTime from $lastSeenTime to $newCheckpointTime" } + lastSeenTime = newCheckpointTime } }