package Ġno . nav . hel se Ċ Ċ import Ġno . nav . hel se . dto . U tb et aling DTO Ċ import Ġno . nav . hel se . rap ids _ river s . Json Message Ċ import Ġno . nav . hel se . rap ids _ river s . Message Problems Ċ import Ġno . nav . hel se . rap ids _ river s . R ap ids Connection Ċ import Ġno . nav . hel se . rap ids _ river s . R iver Ċ import Ġorg . apache . kafka . clients . producer . Kafka Producer Ċ import Ġjava . time . LocalDate Ċ Ċ class ĠU tb et aling Event Message ( ĊĠĠĠ Ġrap ids Connection : ĠR ap ids Connection , ĊĠĠĠ Ġproducer : ĠKafka Producer < String , ĠString > Ċ ) Ġ: ĠR iver . Packet Listener Ġ{ ĊĠĠĠ Ġdata Ġclass ĠU tb et al ings lin je ( ĊĠĠĠĠĠĠĠ Ġval Ġf om : ĠLocalDate , ĊĠĠĠĠĠĠĠ Ġval Ġtom : ĠLocalDate , ĊĠĠĠĠĠĠĠ Ġval Ġd ags ats : ĠInt , ĊĠĠĠĠĠĠĠ Ġval Ġbel Ã¸ p : ĠInt , ĊĠĠĠĠĠĠĠ Ġval Ġgrad : ĠInt , ĊĠĠĠĠĠĠĠ Ġval Ġen Del Av Period en : ĠBoolean , ĊĠĠĠĠĠĠĠ Ġval Ġmot t aker : ĠString , ĊĠĠĠĠĠĠĠ Ġval Ġk onto : ĠString ĊĠĠĠ Ġ) ĊĊĠĠĠ Ġinit Ġ{ ĊĠĠĠĠĠĠĠ ĠR iver ( rap ids Connection ). apply Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġvalidate Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġit . demand Value ("@ event _ name ", Ġ" ut bet alt ") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġit . require Key ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" f Ã¸ d se ls nummer ", Ġ" f Ã¸ r ste Fr av Ã¦ r sd ag ", Ġ" ved tak sp eri ode Id ", Ġ" hen del ser ", Ġ" ut bet al ings lin jer ", ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" for br uk te Sy ked ager ", Ġ" g jen st Ã¥ ende Sy ked ager ", Ġ" op prett et " ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ}. register ( this ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġon Packet ( packet : ĠJson Message , Ġcontext : ĠR ap ids Connection . Message Context ) Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġf Ã¸ d se ls nummer Ġ= Ġpacket [" f Ã¸ d se ls nummer "] ĊĠĠĠĠĠĠĠ Ġval Ġf Ã¸ r ste Fr av Ã¦ r sd ag Ġ= Ġpacket [" f Ã¸ r ste Fr av Ã¦ r sd ag "] ĊĠĠĠĠĠĠĠ Ġval Ġved tak sp eri ode Id Ġ= Ġpacket [" ved tak sp eri ode Id "] ĊĠĠĠĠĠĠĠ Ġval Ġh en del ser Ġ= Ġpacket [" hen del ser "] ĊĠĠĠĠĠĠĠ Ġval Ġut bet al ings lin jer Ġ= Ġpacket [" ut bet al ings lin jer "]. map Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ ĠU tb et aling DTO ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġf om Ġ= Ġit [" f om "]. as Text (). let ( LocalDate :: parse ), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġtom Ġ= Ġit [" tom "]. as Text (). let ( LocalDate :: parse ), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġd ags ats Ġ= Ġit [" d ags ats "]. as Int (), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġbel Ã¸ p Ġ= Ġit [" bel Ã¸ p "]. as Int (), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġgrad Ġ= Ġit [" grad "]. as Int (), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġen Del Av Period en Ġ= Ġit [" en Del Av Per i ode "]. as Boolean (), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġmot t aker Ġ= Ġit [" mot t aker "]. as Text (), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġk onto Ġ= Ġit [" k onto "]. as Text () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĊĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġval Ġfor br uk te Sy ked ager Ġ= Ġpacket [" for br uk te Sy ked ager "] ĊĠĠĠĠĠĠĠ Ġval Ġg jen st Ã¥ ende Sy ked ager Ġ= Ġpacket [" g jen st Ã¥ ende Sy ked ager "] ĊĠĠĠĠĠĠĠ Ġval Ġopp rett et Ġ= Ġpacket [" op prett et "] ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun ĠonError ( problems : ĠMessage Problems , Ġcontext : ĠR ap ids Connection . Message Context ) Ġ{ ĊĊĠĠĠ Ġ} Ċ }