@Bean
fun compoundTriggerAdvice() = CompoundTriggerAdvice(compoundTrigger(), secondaryTrigger())

@Bean
fun compoundTrigger() = CompoundTrigger(primaryTrigger())

@Bean
fun primaryTrigger() = PeriodicTrigger(15, TimeUnit.SECONDS)

@Bean
fun secondaryTrigger()= PeriodicTrigger(1, TimeUnit.SECONDS)

@Bean
fun authMessageSource() = MessageSource<String> {
    GenericMessage("auth-data")
}

@Bean
fun cookieUpdateFlow(cookieStore: CookieStore): IntegrationFlow = IntegrationFlows
    .from(authMessageSource(), Consumer {
        it.poller(Pollers.trigger(compoundTrigger()).advice(compoundTriggerAdvice()))
    })
    .gateway(httpFlow())
    .transform(...)
    .handle(cookieStore)
    .get()

@Bean
fun httpFlow() = IntegrationFlow { f -> f
    .handle(Http.outboundGateway("httpL//localhost:8081/{path}")
        .httpMethod(HttpMethod.POST)
        .uriVariable<Any>("path") { ... }
        .transferCookies(true)
        .expectedResponseType(String::class.java))
}

@Bean
fun dbFlow(em: EntityManager, cookieStore: CookieStore): IntegrationFlow = IntegrationFlows
    .from(Jpa.inboundAdapter(em).entityClass(TestEntity::class.java)) { it.poller(Pollers.fixedDelay(30, TimeUnit.SECONDS)) }
    .enrichHeaders {
        it.headerFunction<Any>(DefaultHttpHeaderMapper.COOKIE) {
            cookieStore.cookie
        }
    }
    .gateway(httpFlow())
    .transform(...)
    .handle(...)
    .get()