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

Interface KafkaMessageExecutionContext

All Superinterfaces:

BaseExecutionContext, NativeMessageExecutionContext

public interface KafkaMessageExecutionContext
extends NativeMessageExecutionContext

Message execution context specialized for Kafka.

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
KafkaExecutionContext	executionContext()	Access the execution context.
io.gravitee.el.TemplateEngine	getTemplateEngine(KafkaMessage message)	Get the TemplateEngine that can be used to evaluate EL expressions.
org.apache.kafka.common.security.auth.KafkaPrincipal	principal()	Access the principal of the current execution context.
KafkaMessageRequest	request()	Get the current request attached to this execution context.
KafkaMessageResponse	response()	Get the current response attached to this execution context when it is available.

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

executionContext

KafkaExecutionContext executionContext()

Access the execution context.

Returns:

the execution context.

request

KafkaMessageRequest request()

Get the current request attached to this execution context.

Returns:

the request.

response

KafkaMessageResponse response()

Get the current response attached to this execution context when it is available.

Returns:

the response.

principal

org.apache.kafka.common.security.auth.KafkaPrincipal principal()

Access the principal of the current execution context.

Returns:

the principal of the current execution context.

getTemplateEngine

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

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

Parameters:

message - the message to evaluate.

Returns:

the El TemplateEngine.