diff --git a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/DelegatingEventListener.kt b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/DelegatingEventListener.kt deleted file mode 100644 index 7787250d3..000000000 --- a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/DelegatingEventListener.kt +++ /dev/null @@ -1,12 +0,0 @@ -package no.nav.helsearbeidsgiver.felles.rapidsrivers - -import no.nav.helse.rapids_rivers.JsonMessage -import no.nav.helse.rapids_rivers.RapidsConnection -import no.nav.helse.rapids_rivers.River - -abstract class DelegatingEventListener(open val mainListener: River.PacketListener, rapidsConnection: RapidsConnection) : EventListener(rapidsConnection) { - - override fun onEvent(packet: JsonMessage) { - mainListener.onPacket(packet, rapidsConnection) - } -} diff --git a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/StatefullEventListener.kt b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/StatefullEventListener.kt index 9a8fa5493..d095d0233 100644 --- a/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/StatefullEventListener.kt +++ b/felles/src/main/kotlin/no/nav/helsearbeidsgiver/felles/rapidsrivers/StatefullEventListener.kt @@ -13,10 +13,9 @@ class StatefullEventListener( val redisStore: IRedisStore, override val event: EventName, private val dataFelter: Array, - override val mainListener: River.PacketListener, + private val mainListener: River.PacketListener, rapidsConnection: RapidsConnection -) : DelegatingEventListener( - mainListener, +) : EventListener( rapidsConnection ) { override fun accept(): River.PacketValidation {