lazzexus/Kafkatorio
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

bump versions (kafka, ktor, hoplite, simple-syslog, factorio, tstl, typed-factorio, kotka, gradle-node) and update code to compile

Browse source
This commit is contained in:
Adam 2022-08-13 12:05:17 +02:00
parent c1542dcb42
commit c9ae17d418
10 changed files with 50 additions and 40 deletions
Download patch file Download diff file Expand all files Collapse all files

18
modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/server/socket/SyslogSocketServer.kt
View file

@ -1,6 +1,9 @@
package dev.adamko.kafkatorio.server.socket
import com.github.palindromicity.syslog.AllowableDeviations
import com.github.palindromicity.syslog.DefaultKeyProvider
import com.github.palindromicity.syslog.Flat5424MessageHandler
import com.github.palindromicity.syslog.NilPolicy
import com.github.palindromicity.syslog.SyslogParser
import com.github.palindromicity.syslog.SyslogParserBuilder
import com.github.palindromicity.syslog.SyslogSpecification
@ -38,10 +41,17 @@ class SyslogSocketServer(
)
private val syslogParser: SyslogParser = SyslogParserBuilder()
.withDeviations(EnumSet.of(AllowableDeviations.PRIORITY, AllowableDeviations.VERSION))
.forSpecification(SyslogSpecification.RFC_5424)
.build()
private val syslogParser: SyslogParser<Map<String, String>> =
SyslogParserBuilder<Map<String, String>>()
.forSpecification(SyslogSpecification.RFC_5424)
.withSyslogBuilder(
Flat5424MessageHandler(
DefaultKeyProvider(),
NilPolicy.OMIT,
EnumSet.of(AllowableDeviations.PRIORITY, AllowableDeviations.VERSION),
)
)
.build()
private val _messages: MutableSharedFlow<SyslogMsg> = MutableSharedFlow()