Uses of Interface
io.gravitee.gateway.reactive.api.context.kafka.KafkaMessageExecutionContext

Packages that use KafkaMessageExecutionContext

Package	Description
io.gravitee.gateway.reactive.api.policy.kafka

Uses of KafkaMessageExecutionContext in io.gravitee.gateway.reactive.api.policy.kafka

Methods in io.gravitee.gateway.reactive.api.policy.kafka with parameters of type KafkaMessageExecutionContext

Modifier and Type	Method	Description
default io.reactivex.rxjava3.core.Completable	KafkaPolicy.onMessageRequest(KafkaMessageExecutionContext ctx)	Define the actions to perform during the ExecutionPhase.MESSAGE_REQUEST phase.
default io.reactivex.rxjava3.core.Completable	KafkaPolicy.onMessageResponse(KafkaMessageExecutionContext ctx)	Define the actions to perform during the ExecutionPhase.MESSAGE_RESPONSE phase.