Package io.gravitee.gateway.reactive.api.context.base

Interface BaseMessageExecutionContext

All Superinterfaces:

BaseExecutionContext

All Known Subinterfaces:

ExecutionContext, HttpExecutionContext, HttpMessageExecutionContext, MessageExecutionContext

public interface BaseMessageExecutionContext
extends BaseExecutionContext

Base interface any message execution context interface can inherit from.

Author:

Jeoffrey HAEYAERT (jeoffrey.haeyaert at graviteesource.com), GraviteeSource Team

Field Summary

Fields

Modifier and Type	Field	Description
static final String	TEMPLATE_ATTRIBUTE_MESSAGE

Fields inherited from interface io.gravitee.gateway.reactive.api.context.base.BaseExecutionContext

TEMPLATE_ATTRIBUTE_CONTEXT

Method Summary

Modifier and Type	Method	Description
io.gravitee.el.TemplateEngine	getTemplateEngine(Message message)	Get the TemplateEngine that can be used to evaluate EL expressions.
io.reactivex.rxjava3.core.Maybe<Message>	interruptMessage()	Same as interruptMessages() but at message level
io.reactivex.rxjava3.core.Flowable<Message>	interruptMessages()	Interrupts the current execution while indicating that the flow of messages can be consumed "as is" to the downstream.

Methods inherited from interface io.gravitee.gateway.reactive.api.context.base.BaseExecutionContext

getAttribute, getAttributeAsList, getAttributeNames, getAttributes, getComponent, getInternalAttribute, getInternalAttributes, getTemplateEngine, getTracer, localAddress, putAttribute, putInternalAttribute, remoteAddress, removeAttribute, removeInternalAttribute, setAttribute, setInternalAttribute, timestamp, tlsSession, warnWith

Field Details

TEMPLATE_ATTRIBUTE_MESSAGE

static final String TEMPLATE_ATTRIBUTE_MESSAGE

See Also:

• Constant Field Values

Method Details

interruptMessages

io.reactivex.rxjava3.core.Flowable<Message> interruptMessages()

Interrupts the current execution while indicating that the flow of messages can be consumed "as is" to the downstream. This has direct impact on how the remaining execution flow will behave (ex: remaining policies in a policy chain won't be executed).

interruptMessage

io.reactivex.rxjava3.core.Maybe<Message> interruptMessage()

Same as interruptMessages() but at message level

getTemplateEngine

io.gravitee.el.TemplateEngine getTemplateEngine(Message message)

Get the TemplateEngine that can be used to evaluate EL expressions.

Returns:

the El TemplateEngine.