package Ġcom . github . ton cher ami . mp d . web . changes . config Ċ Ċ import Ġcom . github . ton cher ami . mp d . web . changes . services . Changes Service Ċ import Ġorg . springframework . context . annotation . Bean Ċ import Ġorg . springframework . context . annotation . Configuration Ċ import Ġorg . springframework . integration . core . Message Source Ċ import Ġorg . springframework . integration . dsl . Integration Flow Ċ import Ġorg . springframework . integration . dsl . Integration Flows Ċ import Ġorg . springframework . integration . endpoint . Method Inv oking Message Source Ċ import Ġkotlin . reflect . jvm . java Method Ċ Ċ const Ġval ĠCH ANG ES _ POL LING _ CHANNEL _ ID Ġ= Ġ" changes Polling Channel " Ċ const Ġval ĠCH ANG ES _ POL LING _ INTEGR ATION _ FLOW _ ID Ġ= Ġ" changes Integration Flow " Ċ Ċ @ Configuration Ċ class ĠChanges Polling Config Ġ{ ĊĊĠĠĠ Ġ@ Bean ( CHANG ES _ POL LING _ INTEGR ATION _ FLOW _ ID ) ĊĠĠĠ Ġfun Ġchanges Integration Flow ( changes Service : ĠChanges Service ): ĠIntegration Flow Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠIntegration Flows ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. from ( get Changes Source ( changes Service )) Ġ{ Ġspec Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġspec . auto Startup ( true ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġspec . pol ler Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġit . fixed Delay ( 0 L ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. channel ( CHANG ES _ POL LING _ CHANNEL _ ID ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. get () ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġprivate Ġfun Ġget Changes Source ( changes Service : ĠChanges Service ): ĠMessage Source < *> Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠMethod Inv oking Message Source (). also Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġit . set Object ( changes Service ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġit . set Method ( changes Service :: get . java Method ) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ Ċ } Ċ