Koblet til brukernotifikasjon

navikt · Jun 9, 2021 · becd444 · becd444
1 parent 590346a
commit becd444
Show file tree

Hide file tree

Showing 2 changed files with 32 additions and 26 deletions.
diff --git a/src/main/kotlin/no/nav/fo/veilarbvarsel/brukernotifikasjonclient/BrukernotifikasjonClient.kt b/src/main/kotlin/no/nav/fo/veilarbvarsel/brukernotifikasjonclient/BrukernotifikasjonClient.kt
@@ -1,28 +1,34 @@
 package no.nav.fo.veilarbvarsel.brukernotifikasjonclient
 
+import no.nav.fo.veilarbvarsel.brukernotifikasjonclient.producers.BrukernotifikasjonBeskjedProducer
+import no.nav.fo.veilarbvarsel.brukernotifikasjonclient.producers.BrukernotifikasjonDoneProducer
+import no.nav.fo.veilarbvarsel.brukernotifikasjonclient.producers.BrukernotifikasjonOppgaveProducer
 import no.nav.fo.veilarbvarsel.config.kafka.utils.KafkaCallback
 import no.nav.fo.veilarbvarsel.varsel.Varsel
+import org.slf4j.LoggerFactory
 
 class BrukernotifikasjonClient(
-//    private val beskjedProducer: BrukernotifikasjonBeskjedProducer,
-//    private val oppgaveProducer: BrukernotifikasjonOppgaveProducer,
-//    private val doneProducer: BrukernotifikasjonDoneProducer
+    private val beskjedProducer: BrukernotifikasjonBeskjedProducer,
+    private val oppgaveProducer: BrukernotifikasjonOppgaveProducer,
+    private val doneProducer: BrukernotifikasjonDoneProducer
 ) {
 
+    private val logger = LoggerFactory.getLogger(javaClass)
+
     fun sendBeskjed(
         varsel: Varsel,
         callback: KafkaCallback
     ) {
-        println("HERE1")
-        //beskjedProducer.send(varsel, callback)
+        logger.info("Sender beskjed til Brukernotifikasjon.")
+        beskjedProducer.send(varsel, callback)
     }
 
     fun sendOppgave(
         varsel: Varsel,
         callback: KafkaCallback
     ) {
-        println("HERE2")
-        //oppgaveProducer.send(varsel, callback)
+        logger.info("Sender oppgave til Brukernotifikasjon.")
+        oppgaveProducer.send(varsel, callback)
     }
 
     fun sendDone(
@@ -31,7 +37,7 @@ class BrukernotifikasjonClient(
         groupId: String,
         callback: KafkaCallback
     ) {
-        println("HERE3")
-        //doneProducer.send(id, fodselsnummer, groupId, callback)
+        logger.info("Sender done til Brukernotifikasjon.")
+        doneProducer.send(id, fodselsnummer, groupId, callback)
     }
 }
diff --git a/src/main/kotlin/no/nav/fo/veilarbvarsel/config/ApplicationContext.kt b/src/main/kotlin/no/nav/fo/veilarbvarsel/config/ApplicationContext.kt
@@ -26,24 +26,24 @@ class ApplicationContext {
 //    )
 
 
-//    val beskjedProducer = BrukernotifikasjonBeskjedProducer(
-//        env = environment.kafka,
-//        systemUser = environment.systemUser,
-//        topic = environment.kafkaTopics.doknotifikasjonBeskjed
-//    )
-//    val oppgaveProducer = BrukernotifikasjonOppgaveProducer(
-//        env = environment.kafka,
-//        systemUser = environment.systemUser,
-//        topic = environment.kafkaTopics.doknotifikasjonOppgave
-//    )
-//    val doneProducer = BrukernotifikasjonDoneProducer(
-//        env = environment.kafka,
-//        systemUser = environment.systemUser,
-//        topic = environment.kafkaTopics.doknotifikasjonDone
-//    )
+    val beskjedProducer = BrukernotifikasjonBeskjedProducer(
+        env = environment.kafka,
+        systemUser = environment.systemUser,
+        topic = environment.kafkaTopics.doknotifikasjonBeskjed
+    )
+    val oppgaveProducer = BrukernotifikasjonOppgaveProducer(
+        env = environment.kafka,
+        systemUser = environment.systemUser,
+        topic = environment.kafkaTopics.doknotifikasjonOppgave
+    )
+    val doneProducer = BrukernotifikasjonDoneProducer(
+        env = environment.kafka,
+        systemUser = environment.systemUser,
+        topic = environment.kafkaTopics.doknotifikasjonDone
+    )
 
-    //val brukernotifikasjonClient = BrukernotifikasjonClient(beskjedProducer, oppgaveProducer, doneProducer)
-    val brukernotifikasjonClient = BrukernotifikasjonClient()
+    val brukernotifikasjonClient = BrukernotifikasjonClient(beskjedProducer, oppgaveProducer, doneProducer)
+    //val brukernotifikasjonClient = BrukernotifikasjonClient()
     val varselService = VarselService(brukernotifikasjonClient)
 
     val eventConsumer = VarselEventConsumer(