Uses of Interface
io.gravitee.gateway.reactive.api.context.kafka.KafkaExecutionContext
Packages that use KafkaExecutionContext
Package
Description
-
Uses of KafkaExecutionContext in io.gravitee.gateway.reactive.api.context.kafka
Methods in io.gravitee.gateway.reactive.api.context.kafka that return KafkaExecutionContextModifier and TypeMethodDescriptionKafkaMessageExecutionContext.executionContext()Access the execution context.Method parameters in io.gravitee.gateway.reactive.api.context.kafka with type arguments of type KafkaExecutionContextModifier and TypeMethodDescriptionvoidKafkaExecutionContext.addActionOnResponse(Function<KafkaExecutionContext, io.reactivex.rxjava3.core.Completable> onResponseCallback) Allows defining an action in the request phase to be executed at the response phase. -
Uses of KafkaExecutionContext in io.gravitee.gateway.reactive.api.policy.kafka
Methods in io.gravitee.gateway.reactive.api.policy.kafka with parameters of type KafkaExecutionContextModifier and TypeMethodDescriptiondefault io.reactivex.rxjava3.core.CompletableKafkaPolicy.onRequest(KafkaExecutionContext ctx) Define the actions to perform during theExecutionPhase.REQUESTphase.default io.reactivex.rxjava3.core.CompletableKafkaPolicy.onResponse(KafkaExecutionContext ctx) Define the actions to perform during theExecutionPhase.RESPONSEphase.