package Ġno . nav . na is . mot . bm ot 0 0 9 Ċ Ċ import Ġkotlinx . coroutines . Global Scope Ċ import Ġkotlinx . coroutines . async Ċ import Ġkotlinx . coroutines . delay Ċ import Ġkotlinx . coroutines . run Blocking Ċ import Ġorg . apache . camel . Exchange Ċ import Ġorg . apache . camel . Processor Ċ Ċ class ĠSocial Security Processor : ĠProcessor Ġ{ ĊĠĠĠ Ġ// TODO Ġremove Ġ!! Ġ? ĊĠĠĠ Ġoverride Ġfun Ġprocess ( exchange : ĠExchange ?) Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġtext Ġ: ĠString Ġ= Ġexchange !!. getIn (). getBody ( String :: class . java ) ĊĠĠĠĠĠĠĠ Ġprintln ( text ) ĊĊĠĠĠĠĠĠĠ Ġ// todo Ġcor utine Ġcalls Ġto Ġproviders ĊĠĠĠĠĠĠĠ Ġval Ġperson List Ġ= Ġtext . split ("\ n ") ĊĊĠĠĠĠĠĠĠ Ġval Ġperson Job Ġ= Ġperson List . map Ġ{ Ġn Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ ĠGlobal Scope . async Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġdelay ( 5 0 0 0 ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ// call Ġ 1 ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ// call Ġ 2 ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ// call Ġ 3 ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠPerson ( n ). toFixed Record Format () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġrun Blocking Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġperson er Ġ= Ġperson Job . map Ġ{ Ġit . await () Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ// todo Ġcreate Ġprop per Ġstream writer ĊĠĠĠĠĠĠĠĠĠĠĠ Ġexchange . getIn (). body Ġ= Ġperson er . reduce Ġ{ Ġacc , Ġb Ġ-> Ġacc Ġ+ Ġb Ġ Ġ} ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ }