Uses of Interface
io.gravitee.gateway.reactive.api.message.Message

Packages that use Message

Package	Description
io.gravitee.gateway.reactive.api.connector.entrypoint.async
io.gravitee.gateway.reactive.api.context.base
io.gravitee.gateway.reactive.api.context.http
io.gravitee.gateway.reactive.api.el
io.gravitee.gateway.reactive.api.hook
io.gravitee.gateway.reactive.api.message
io.gravitee.gateway.reactive.api.message.kafka
io.gravitee.gateway.reactive.api.service.dlq
io.gravitee.gateway.reactive.api.tracing.message

Uses of Message in io.gravitee.gateway.reactive.api.connector.entrypoint.async

Fields in io.gravitee.gateway.reactive.api.connector.entrypoint.async with type parameters of type Message

Modifier and Type	Field	Description
protected io.reactivex.rxjava3.processors.BehaviorProcessor<Message>	HttpEntrypointAsyncConnector.stopHook

Methods in io.gravitee.gateway.reactive.api.connector.entrypoint.async that return types with arguments of type Message

Modifier and Type	Method	Description
protected io.reactivex.rxjava3.core.FlowableTransformer<Message,Message>	HttpEntrypointAsyncConnector.applyStopHook()
protected io.reactivex.rxjava3.core.FlowableTransformer<Message,Message>	HttpEntrypointAsyncConnector.applyStopHook()

Uses of Message in io.gravitee.gateway.reactive.api.context.base

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

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Maybe<Message>	BaseMessageExecutionContext.interruptMessage()	Same as BaseMessageExecutionContext.interruptMessages() but at message level
io.reactivex.rxjava3.core.Flowable<Message>	BaseMessageExecutionContext.interruptMessages()	Interrupts the current execution while indicating that the flow of messages can be consumed "as is" to the downstream.
io.reactivex.rxjava3.core.Flowable<Message>	BaseMessageRequest.messages()	Get the request message flow as a Flowable of Message.
io.reactivex.rxjava3.core.Flowable<Message>	BaseMessageResponse.messages()	Get the response message flow as a Flowable of Message.

Methods in io.gravitee.gateway.reactive.api.context.base with parameters of type Message

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

Method parameters in io.gravitee.gateway.reactive.api.context.base with type arguments of type Message

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

Uses of Message in io.gravitee.gateway.reactive.api.context.http

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

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Flowable<Message>	HttpMessageExecutionContext.interruptMessagesWith(ExecutionFailure failure)	Same as BaseMessageExecutionContext.interruptMessages() but with an ExecutionFailure object that indicates that the execution has failed.
io.reactivex.rxjava3.core.Maybe<Message>	HttpMessageExecutionContext.interruptMessageWith(ExecutionFailure failure)	Same as BaseMessageExecutionContext#interruptMessagesWith(ExecutionFailure) but at message level
io.reactivex.rxjava3.core.Flowable<Message>	HttpMessageRequest.messages()	Get the request message flow as a Flowable of Message.
io.reactivex.rxjava3.core.Flowable<Message>	HttpMessageResponse.messages()	Get the response message flow as a Flowable of Message.

Method parameters in io.gravitee.gateway.reactive.api.context.http with type arguments of type Message

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

Uses of Message in io.gravitee.gateway.reactive.api.el

Constructors in io.gravitee.gateway.reactive.api.el with parameters of type Message

Modifier	Constructor	Description
	EvaluableMessage(Message message)

Uses of Message in io.gravitee.gateway.reactive.api.hook

Methods in io.gravitee.gateway.reactive.api.hook with parameters of type Message

Modifier and Type	Method	Description
default void	MessageHook.cancelMessage(String id, HttpMessageExecutionContext ctx, ExecutionPhase executionPhase, Message message)
default io.reactivex.rxjava3.core.Completable	MessageHook.errorMessage(String id, HttpMessageExecutionContext ctx, ExecutionPhase executionPhase, Message message, Throwable throwable)
default io.reactivex.rxjava3.core.Completable	MessageHook.interruptMessage(String id, HttpMessageExecutionContext ctx, ExecutionPhase executionPhase, Message message)
default io.reactivex.rxjava3.core.Completable	MessageHook.interruptMessageWith(String id, HttpMessageExecutionContext ctx, ExecutionPhase executionPhase, Message message, ExecutionFailure failure)
default io.reactivex.rxjava3.core.Completable	MessageHook.postMessage(String id, HttpMessageExecutionContext ctx, ExecutionPhase executionPhase, Message message)
default io.reactivex.rxjava3.core.Completable	MessageHook.preMessage(String id, HttpMessageExecutionContext ctx, ExecutionPhase executionPhase, Message message)

Uses of Message in io.gravitee.gateway.reactive.api.message

Classes in io.gravitee.gateway.reactive.api.message that implement Message

Modifier and Type	Class	Description
class	AbstractMessage
class	DefaultMessage

Methods in io.gravitee.gateway.reactive.api.message that return Message

Modifier and Type	Method	Description
Message	AbstractMessage.attribute(String name, Object value)
Message	Message.attribute(String name, Object value)	Stores an attribute in this message.
Message	Message.content(Buffer content)	Set the content of the message.
Message	Message.content(String content)	Set the content of the message.
Message	Message.error(boolean error)	Flag indicating the message is in error.
Message	Message.headers(HttpHeaders headers)	Set the headers of the message.
Message	AbstractMessage.internalAttribute(String name, Object value)
Message	Message.internalAttribute(String name, Object value)	Stores an internal attribute in this message.
Message	AbstractMessage.removeAttribute(String name)
Message	Message.removeAttribute(String name)	Removes an attribute from this request.
Message	AbstractMessage.removeInternalAttribute(String name)
Message	Message.removeInternalAttribute(String name)	Removes an internal attribute from this request.

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

Subinterfaces of Message in io.gravitee.gateway.reactive.api.message.kafka

Modifier and Type	Interface	Description
interface	KafkaMessage

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

Modifier and Type	Method	Description
default Message	KafkaMessage.headers(HttpHeaders headers)	Deprecated.

Uses of Message in io.gravitee.gateway.reactive.api.service.dlq

Methods in io.gravitee.gateway.reactive.api.service.dlq that return types with arguments of type Message

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Flowable<Message>	DlqService.apply(io.reactivex.rxjava3.core.Flowable<Message> messages)	Set up the dead letter queue mechanism on the incoming flow of messages.

Method parameters in io.gravitee.gateway.reactive.api.service.dlq with type arguments of type Message

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Flowable<Message>	DlqService.apply(io.reactivex.rxjava3.core.Flowable<Message> messages)	Set up the dead letter queue mechanism on the incoming flow of messages.

Uses of Message in io.gravitee.gateway.reactive.api.tracing.message

Subinterfaces of Message in io.gravitee.gateway.reactive.api.tracing.message

Modifier and Type	Interface	Description
interface	TracingMessage	This interface defines a Message compatible with tracing