/* Ċ Ġ* ĠCopyright Ġ( c ) Ġ 2 0 2 0 . ĠThe ĠOpen ĠData ĠManagement ĠPlatform Ġcontributors . Ċ Ġ* Ċ Ġ* ĠLicensed Ġunder Ġthe ĠApache ĠLicense , ĠVersion Ġ 2 . 0 Ġ( the Ġ" License "); Ċ Ġ* Ġyou Ġmay Ġnot Ġuse Ġthis Ġfile Ġexcept Ġin Ġcompliance Ġwith Ġthe ĠLicense . Ċ Ġ* ĠYou Ġmay Ġobtain Ġa Ġcopy Ġof Ġthe ĠLicense Ġat Ċ Ġ* Ċ Ġ* Ġhttp :// www . apache . org / licenses / LICENSE - 2 . 0 Ċ Ġ* Ċ Ġ* ĠUnless Ġrequired Ġby Ġapplicable Ġlaw Ġor Ġagreed Ġto Ġin Ġwriting , Ġsoftware Ċ Ġ* Ġdistributed Ġunder Ġthe ĠLicense Ġis Ġdistributed Ġon Ġan Ġ" AS ĠIS " ĠBASIS , Ċ Ġ* ĠWITHOUT ĠWARRANTIES ĠOR ĠCONDITIONS ĠOF ĠANY ĠKIND , Ġeither Ġexpress Ġor Ġimplied . Ċ Ġ* ĠSee Ġthe ĠLicense Ġfor Ġthe Ġspecific Ġlanguage Ġgoverning Ġpermissions Ġand Ċ Ġ* Ġlimitations Ġunder Ġthe ĠLicense . Ċ Ġ*/ Ċ Ċ package Ġio . opend mp . data flow . config Ċ Ċ import Ġio . opend mp . data flow . model . Data flow Model Ċ import Ġio . opend mp . data flow . model . run plan . Run Plan Model Ċ import Ġkotlinx . coroutines . reactive . await Last Ċ import Ġorg . slf 4 j . LoggerFactory Ċ import Ġorg . springframework . beans . factory . annotation . Autowired Ċ import Ġorg . springframework . data . mongodb . core . Reactive Mongo Template Ċ import Ġorg . springframework . data . mongodb . core . find Ċ import Ġorg . springframework . data . mongodb . core . findAll And Remove Ċ import Ġorg . springframework . data . mongodb . core . query . Criteria Ċ import Ġorg . springframework . data . mongodb . core . query . Query Ċ import Ġorg . springframework . data . mongodb . core . query . isEqualTo Ċ import Ġorg . springframework . stereotype . Component Ċ import Ġjavax . annotation . Pre Destroy Ċ Ċ @ Component Ċ class ĠLifecycle Ġ@ Autowired Ġconstructor ( private Ġval Ġmongo Template : ĠReactive Mongo Template ) Ġ{ ĊĊĠĠĠ Ġprivate Ġval Ġlog Ġ= ĠLoggerFactory . getLogger ( Lifecycle :: class . java ) ĊĊĠĠĠ Ġ@ Pre Destroy ĊĠĠĠ Ġfun Ġshut Down () Ġ{ ĊĠĠĠĠĠĠĠ Ġlog . info (" Shut ting Ġdown ...") ĊĠĠĠ Ġ} Ċ Ċ }