Shift
This commit is contained in:
parent
d31448e26c
commit
746dc2dc67
@ -51,16 +51,15 @@ abstract class EventPollerImplementation(
|
|||||||
// Samle persistedAt KUN for referanser vi faktisk dispatch’et
|
// Samle persistedAt KUN for referanser vi faktisk dispatch’et
|
||||||
val processedTimes = mutableListOf<LocalDateTime>()
|
val processedTimes = mutableListOf<LocalDateTime>()
|
||||||
|
|
||||||
for ((referenceId, eventsForRef) in grouped) {
|
for ((referenceId, _) in grouped) {
|
||||||
if (dispatchQueue.isProcessing(referenceId)) {
|
if (dispatchQueue.isProcessing(referenceId)) {
|
||||||
log.debug { "Skipping dispatch for $referenceId as it is already being processed" }
|
log.debug { "Skipping dispatch for $referenceId as it is already being processed" }
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
val fullLog = eventStore.getPersistedEventsFor(referenceId)
|
val fullLog = eventStore.getPersistedEventsFor(referenceId)
|
||||||
processedTimes += fullLog.map { it.persistedAt }
|
|
||||||
|
|
||||||
val events = fullLog.mapNotNull { it.toEvent() }
|
val events = fullLog.mapNotNull { it.toEvent() }
|
||||||
|
processedTimes += fullLog.map { it.persistedAt }
|
||||||
dispatchQueue.dispatch(referenceId, events, dispatcher)
|
dispatchQueue.dispatch(referenceId, events, dispatcher)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user