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

Updated filter

Browse Source
This commit is contained in:
Brage 2024-03-25 18:39:13 +01:00
parent 4f3be9a642
commit 876d900e9b
3 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CompleteRequestTask.kt
View File

@ -19,7 +19,7 @@ import org.springframework.stereotype.Service
class CompleteRequestTask(@Autowired override var coordinator: Coordinator) : TaskCreator(coordinator) {
val log = KotlinLogging.logger {}
override val producesEvent: KafkaEvents = KafkaEvents.EVENT_MEDIA_PROCESS_COMPLETED
override val producesEvent: KafkaEvents = KafkaEvents.EVENT_REQUEST_PROCESS_COMPLETED
override val requiredEvents: List<KafkaEvents> = listOf(
EVENT_REQUEST_PROCESS_STARTED,

10
shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/persistance/PersistentDataStore.kt
View File

@ -1,5 +1,6 @@
package no.iktdev.mediaprocessing.shared.common.persistance
import mu.KotlinLogging
import no.iktdev.mediaprocessing.shared.common.datasource.executeOrException
import no.iktdev.mediaprocessing.shared.common.datasource.executeWithStatus
import no.iktdev.mediaprocessing.shared.common.datasource.withTransaction
@ -11,6 +12,7 @@ import org.jetbrains.exposed.sql.javatime.CurrentDateTime
import org.jetbrains.exposed.sql.update
import java.sql.SQLIntegrityConstraintViolationException
private val log = KotlinLogging.logger {}
open class PersistentDataStore {
fun storeEventDataMessage(event: String, message: Message<*>): Boolean {
val exception = executeOrException {
@ -23,7 +25,13 @@ open class PersistentDataStore {
}
return if (exception == null) true else {
if (exception.cause is SQLIntegrityConstraintViolationException) {
exception.printStackTrace()
log.info { "Error is of SQLIntegrityConstraintViolationException" }
try {
log.info { "Error code is: ${ (exception as ExposedSQLException).errorCode}" }
} catch (e: Exception) {
}
//exception.printStackTrace()
(exception as ExposedSQLException).errorCode == 1062
}
else {

4
shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/tasks/TaskCreatorImpl.kt
View File

@ -20,9 +20,9 @@ abstract class TaskCreatorImpl<C : CoordinatorBase<V, L>, V, L : EventBasedMessa
@Autowired
lateinit var producer: CoordinatorProducer
fun getListener(): Tasks<V> {
val reactableEvents: Set<KafkaEvents> = requiredEvents.toSet() + listensForEvents.toSet()
val reactableEvents = (requiredEvents + listensForEvents).distinct()
//val eventListenerFilter = listensForEvents.ifEmpty { requiredEvents }
return Tasks(taskHandler = this, producesEvent = producesEvent, listensForEvents = reactableEvents.toList())
return Tasks(taskHandler = this, producesEvent = producesEvent, listensForEvents = reactableEvents)
}
@PostConstruct
fun attachListener() {