pcvolkmer/grz-metadata-processor
1
0
Fork 0
mirror of https://github.com/pcvolkmer/grz-metadata-processor.git synced 2025-07-01 12:02:54 +00:00
Code Issues Activity

feat: use watch service if no poll delay is set

Browse Source
This commit is contained in:
Paul-Christian Volkmer
2025-06-10 20:27:06 +02:00
parent 9567dbcfee
commit 3d20acf397
1 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/main/kotlin/dev/pcvolkmer/onco/grzmetadataprocessor/config/AppIntegrationConfig.kt
View File

@ -4,6 +4,7 @@ import dev.pcvolkmer.onco.grzmetadataprocessor.data.File
import dev.pcvolkmer.onco.grzmetadataprocessor.data.FileRepository
import dev.pcvolkmer.onco.grzmetadataprocessor.data.FileType
import org.apache.tomcat.util.buf.HexUtils
import org.slf4j.LoggerFactory
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty
import org.springframework.boot.context.properties.ConfigurationProperties
import org.springframework.boot.context.properties.EnableConfigurationProperties
@ -18,13 +19,11 @@ import java.security.DigestInputStream
import java.security.MessageDigest
import java.time.Duration
import kotlin.io.path.*
import kotlin.time.Duration.Companion.minutes
import kotlin.time.toJavaDuration
@ConfigurationProperties(AppSourceFsProperties.NAME)
data class AppSourceFsProperties(
val directory: Path? = null,
val pollDelay: Duration = 1.minutes.toJavaDuration(),
val pollDelay: Duration? = null,
) {
companion object {
const val NAME = "app.source.fs"
@ -35,6 +34,8 @@ data class AppSourceFsProperties(
@EnableConfigurationProperties(AppSourceFsProperties::class)
class AppIntegrationConfig {
private val logger = LoggerFactory.getLogger(AppSourceFsProperties::class.java)
@Bean
@ConditionalOnProperty(
name = ["app.source.fs.directory"]
@ -50,7 +51,12 @@ class AppIntegrationConfig {
return IntegrationFlow
.from(
Files.inboundAdapter(sourceDirectory!!.toFile()).useWatchService(true)
)
) {
if (applicationFsProperties.pollDelay != null) {
logger.info("Polling new file each ${applicationFsProperties.pollDelay.seconds} seconds...")
it.poller(Pollers.fixedDelay(applicationFsProperties.pollDelay))
}
}
.log()
.handle { msg ->
val path = Path(msg.payload.toString())