Uses of Interface
io.gravitee.gateway.reactive.api.message.kafka.KafkaMessage

Packages that use KafkaMessage

Package	Description
io.gravitee.gateway.reactive.api.context.kafka
io.gravitee.gateway.reactive.api.message.kafka

Uses of KafkaMessage in io.gravitee.gateway.reactive.api.context.kafka

Methods in io.gravitee.gateway.reactive.api.context.kafka that return types with arguments of type KafkaMessage

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Flowable<KafkaMessage>	KafkaMessageRequest.messages()	Get the flow of messages.
io.reactivex.rxjava3.core.Flowable<KafkaMessage>	KafkaMessageResponse.messages()	Get the flow of messages.

Methods in io.gravitee.gateway.reactive.api.context.kafka with parameters of type KafkaMessage

Modifier and Type	Method	Description
io.gravitee.el.TemplateEngine	KafkaMessageExecutionContext.getTemplateEngine(KafkaMessage message)	Get the TemplateEngine that can be used to evaluate EL expressions.

Method parameters in io.gravitee.gateway.reactive.api.context.kafka with type arguments of type KafkaMessage

Modifier and Type	Method	Description
void	KafkaMessageRequest.messages(io.reactivex.rxjava3.core.Flowable<KafkaMessage> messages)	Set the request message flow.
void	KafkaMessageResponse.messages(io.reactivex.rxjava3.core.Flowable<KafkaMessage> messages)	Set the request message flow.
default io.reactivex.rxjava3.core.Completable	KafkaMessageRequest.onMessage(Function<KafkaMessage,io.reactivex.rxjava3.core.Maybe<KafkaMessage>> onMessage)	Applies a given transformation on each message.
default io.reactivex.rxjava3.core.Completable	KafkaMessageRequest.onMessage(Function<KafkaMessage,io.reactivex.rxjava3.core.Maybe<KafkaMessage>> onMessage)	Applies a given transformation on each message.
default io.reactivex.rxjava3.core.Completable	KafkaMessageResponse.onMessage(Function<KafkaMessage,io.reactivex.rxjava3.core.Maybe<KafkaMessage>> onMessage)	Applies a given transformation on each message.
default io.reactivex.rxjava3.core.Completable	KafkaMessageResponse.onMessage(Function<KafkaMessage,io.reactivex.rxjava3.core.Maybe<KafkaMessage>> onMessage)	Applies a given transformation on each message.
io.reactivex.rxjava3.core.Completable	KafkaMessageRequest.onMessages(io.reactivex.rxjava3.core.FlowableTransformer<KafkaMessage,KafkaMessage> onMessages)	Applies a given transformation on each message.
io.reactivex.rxjava3.core.Completable	KafkaMessageRequest.onMessages(io.reactivex.rxjava3.core.FlowableTransformer<KafkaMessage,KafkaMessage> onMessages)	Applies a given transformation on each message.
io.reactivex.rxjava3.core.Completable	KafkaMessageResponse.onMessages(io.reactivex.rxjava3.core.FlowableTransformer<KafkaMessage,KafkaMessage> onMessages)	Applies a given transformation on each message.
io.reactivex.rxjava3.core.Completable	KafkaMessageResponse.onMessages(io.reactivex.rxjava3.core.FlowableTransformer<KafkaMessage,KafkaMessage> onMessages)	Applies a given transformation on each message.

Uses of KafkaMessage in io.gravitee.gateway.reactive.api.message.kafka

Methods in io.gravitee.gateway.reactive.api.message.kafka that return KafkaMessage

Modifier and Type	Method	Description
KafkaMessage	KafkaMessage.key(Buffer key)	Set the Kafka record key associated with the message.
KafkaMessage	KafkaMessage.key(String key)	Overloaded setter for the Kafka key accepting a String.
KafkaMessage	KafkaMessage.putRecordHeader(String key, Buffer value)	FIXME: Refactor/remove this method when Message.headers(HttpHeaders) are http agnostic Put a Kafka record header to the message.
KafkaMessage	KafkaMessage.removeRecordHeader(String key)	FIXME: Refactor/remove this method when Message.headers(HttpHeaders) are http agnostic Remove a Kafka record header from the message.