chore: change kafka topic subscription

andrea-acampora · andrea-acampora · commit b0a13473d82b · 2023-06-01T16:05:10.000+02:00
diff --git a/src/main/kotlin/infrastructure/event/EventManagerVerticle.kt b/src/main/kotlin/infrastructure/event/EventManagerVerticle.kt
@@ -67,9 +67,7 @@ class EventManagerVerticle : AbstractVerticle() {
                 KafkaProducerRecord.create(Topics.automationRequestsEventsTopic, event.key, message.body()),
             )
         }
-
-        kafkaConsumer.subscribe(Topics.automationProposalsEventsTopic)
-        kafkaConsumer.handler(KafkaEventHandler(vertx))
+        kafkaConsumer.handler(KafkaEventHandler(vertx)).subscribe(Topics.automationProposalsEventsTopic)
     }
 
     companion object {

Original file line number	Diff line number	Diff line change
`@@ -67,9 +67,7 @@ class EventManagerVerticle : AbstractVerticle() {`
`67`	`67`	`KafkaProducerRecord.create(Topics.automationRequestsEventsTopic, event.key, message.body()),`
`68`	`68`	`)`
`69`	`69`	`}`
`70`		`-`
`71`		`- kafkaConsumer.subscribe(Topics.automationProposalsEventsTopic)`
`72`		`- kafkaConsumer.handler(KafkaEventHandler(vertx))`
	`70`	`+ kafkaConsumer.handler(KafkaEventHandler(vertx)).subscribe(Topics.automationProposalsEventsTopic)`
`73`	`71`	`}`
`74`	`72`
`75`	`73`	`companion object {`