close #154: fixed serializer (#155)

Marchosiax · web-flow · commit 9ace6a08a79f · 2021-11-28T11:06:47.000+03:30
diff --git a/accountant/accountant-ports/accountant-eventlistener-kafka/src/main/kotlin/co/nilin/opex/accountant/ports/kafka/listener/config/AccountantKafkaConfig.kt b/accountant/accountant-ports/accountant-eventlistener-kafka/src/main/kotlin/co/nilin/opex/accountant/ports/kafka/listener/config/AccountantKafkaConfig.kt
@@ -41,6 +41,7 @@ class AccountantKafkaConfig {
         props[ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG] = StringDeserializer::class.java
         props[ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG] = JsonDeserializer::class.java
         props[JsonDeserializer.TRUSTED_PACKAGES] = "co.nilin.opex.*"
+        props[JsonDeserializer.TYPE_MAPPINGS] = "order_request:co.nilin.opex.accountant.ports.kafka.listener.inout.OrderSubmitRequest"
         return props
     }
 
diff --git a/matching-engine/matching-engine-ports/matching-engine-eventlistener-kafka/src/main/kotlin/co/nilin/opex/matching/engine/ports/kafka/listener/config/OrderKafkaConfig.kt b/matching-engine/matching-engine-ports/matching-engine-eventlistener-kafka/src/main/kotlin/co/nilin/opex/matching/engine/ports/kafka/listener/config/OrderKafkaConfig.kt
@@ -73,6 +73,7 @@ class OrderKafkaConfig {
         props[ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG] = StringDeserializer::class.java
         props[ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG] = JsonDeserializer::class.java
         props[JsonDeserializer.TRUSTED_PACKAGES] = "co.nilin.opex.*"
+        props[JsonDeserializer.TYPE_MAPPINGS] = "order_request:co.nilin.opex.matching.engine.ports.kafka.listener.inout.OrderSubmitRequest"
         return props
     }
 
diff --git a/matching-engine/matching-engine-ports/matching-engine-eventlistener-kafka/src/main/kotlin/co/nilin/opex/matching/engine/ports/kafka/listener/inout/OrderSubmitRequest.kt b/matching-engine/matching-engine-ports/matching-engine-eventlistener-kafka/src/main/kotlin/co/nilin/opex/matching/engine/ports/kafka/listener/inout/OrderSubmitRequest.kt
@@ -17,7 +17,6 @@ class OrderSubmitRequest() {
     var matchConstraint: MatchConstraint = MatchConstraint.GTC
     var orderType: OrderType = OrderType.LIMIT_ORDER
 
-
     constructor(
         ouid: String,
         uuid: String,
@@ -39,6 +38,4 @@ class OrderSubmitRequest() {
         this.matchConstraint = matchConstraint
         this.orderType = orderType
     }
-
-
 }
diff --git a/matching-gateway/matching-gateway-port/matching-gateway-submitter-kafka/src/main/kotlin/co/nilin/opex/matching/gateway/ports/kafka/submitter/config/OrderKafkaConfig.kt b/matching-gateway/matching-gateway-port/matching-gateway-submitter-kafka/src/main/kotlin/co/nilin/opex/matching/gateway/ports/kafka/submitter/config/OrderKafkaConfig.kt
@@ -25,6 +25,7 @@ class OrderKafkaConfig {
         props[ProducerConfig.BOOTSTRAP_SERVERS_CONFIG] = bootstrapServers
         props[ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG] = StringSerializer::class.java
         props[ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG] = JsonSerializer::class.java
+        props[JsonSerializer.TYPE_MAPPINGS] = "order_request:co.nilin.opex.matching.gateway.ports.kafka.submitter.inout.OrderSubmitRequest"
         return props
     }
 

Original file line number	Diff line number	Diff line change
`@@ -41,6 +41,7 @@ class AccountantKafkaConfig {`
`41`	`41`	`props[ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG] = StringDeserializer::class.java`
`42`	`42`	`props[ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG] = JsonDeserializer::class.java`
`43`	`43`	`props[JsonDeserializer.TRUSTED_PACKAGES] = "co.nilin.opex.*"`
	`44`	`+ props[JsonDeserializer.TYPE_MAPPINGS] = "order_request:co.nilin.opex.accountant.ports.kafka.listener.inout.OrderSubmitRequest"`
`44`	`45`	`return props`
`45`	`46`	`}`
`46`	`47`
Original file line number	Diff line number	Diff line change
`@@ -73,6 +73,7 @@ class OrderKafkaConfig {`
`73`	`73`	`props[ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG] = StringDeserializer::class.java`
`74`	`74`	`props[ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG] = JsonDeserializer::class.java`
`75`	`75`	`props[JsonDeserializer.TRUSTED_PACKAGES] = "co.nilin.opex.*"`
	`76`	`+ props[JsonDeserializer.TYPE_MAPPINGS] = "order_request:co.nilin.opex.matching.engine.ports.kafka.listener.inout.OrderSubmitRequest"`
`76`	`77`	`return props`
`77`	`78`	`}`
`78`	`79`
Original file line number	Diff line number	Diff line change
`@@ -17,7 +17,6 @@ class OrderSubmitRequest() {`
`17`	`17`	`var matchConstraint: MatchConstraint = MatchConstraint.GTC`
`18`	`18`	`var orderType: OrderType = OrderType.LIMIT_ORDER`
`19`	`19`
`20`		`-`
`21`	`20`	`constructor(`
`22`	`21`	`ouid: String,`
`23`	`22`	`uuid: String,`
`@@ -39,6 +38,4 @@ class OrderSubmitRequest() {`
`39`	`38`	`this.matchConstraint = matchConstraint`
`40`	`39`	`this.orderType = orderType`
`41`	`40`	`}`
`42`		`-`
`43`		`-`
`44`	`41`	`}`
Original file line number	Diff line number	Diff line change
`@@ -25,6 +25,7 @@ class OrderKafkaConfig {`
`25`	`25`	`props[ProducerConfig.BOOTSTRAP_SERVERS_CONFIG] = bootstrapServers`
`26`	`26`	`props[ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG] = StringSerializer::class.java`
`27`	`27`	`props[ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG] = JsonSerializer::class.java`
	`28`	`+ props[JsonSerializer.TYPE_MAPPINGS] = "order_request:co.nilin.opex.matching.gateway.ports.kafka.submitter.inout.OrderSubmitRequest"`
`28`	`29`	`return props`
`29`	`30`	`}`
`30`	`31`