iktdev/MediaProcessing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Changed behaviour

Browse Source
This commit is contained in:
bskjon 2024-04-21 21:34:32 +02:00
parent b245cf6f94
commit f3c5beaacd
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/persistance/PersistentEventManager.kt
View File

@ -177,16 +177,18 @@ class PersistentEventManager(private val dataSource: DataSource) {
} }
} }
val exception = executeOrException(dataSource.database) { withTransaction(dataSource.database) {
events.insert { allEvents.insert {
it[referenceId] = message.referenceId it[referenceId] = message.referenceId
it[eventId] = message.eventId it[eventId] = message.eventId
it[events.event] = event.event it[events.event] = event.event
it[integrity] = getIntegrityOfData(message.dataAsJson()) it[integrity] = getIntegrityOfData(message.dataAsJson())
it[data] = message.dataAsJson() it[data] = message.dataAsJson()
} }
}
allEvents.insert { val exception = executeOrException(dataSource.database) {
events.insert {
it[referenceId] = message.referenceId it[referenceId] = message.referenceId
it[eventId] = message.eventId it[eventId] = message.eventId
it[events.event] = event.event it[events.event] = event.event