Package io.gravitee.gateway.reactive.api.message

Class DefaultMessage

java.lang.Object

io.gravitee.gateway.reactive.api.message.AbstractMessage

io.gravitee.gateway.reactive.api.message.DefaultMessage

All Implemented Interfaces:

Message, TracingMessage

public class DefaultMessage
extends AbstractMessage
implements TracingMessage

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DefaultMessage.DefaultMessageBuilder

Field Summary

Fields inherited from class io.gravitee.gateway.reactive.api.message.AbstractMessage

attributes, internalAttributes, metadata, SOURCE_TIMESTAMP, sourceTimestamp, timestamp

Method Summary

Modifier and Type	Method	Description
void	ack()	MUST be called to acknowledge this message when it has been well-processed.
void	addTracingAttribute(String key, String value)	Allow to add extra tracing attribute used to trace this message
static DefaultMessage.DefaultMessageBuilder	builder()
DefaultMessage	content(Buffer content)	Set the content of the message.
DefaultMessage	content(String content)	Set the content of the message.
DefaultMessage	doOnEnd(Runnable runnable)	Behavior to apply when the underlying span will be ended.
void	end()	Run the end behavior defined by TracingMessage.doOnEnd(Runnable)
HttpHeaders	headers()	Get the headers of the message.
Map<String,String>	tracingAttributes()	Return tracing attributes based on Semantic Conventions for Messaging

Methods inherited from class io.gravitee.gateway.reactive.api.message.AbstractMessage

attribute, attribute, attributeAsList, attributeNames, attributes, internalAttribute, internalAttribute, internalAttributeNames, internalAttributes, metadata, removeAttribute, removeInternalAttribute, timestamp, unmodifiableMetadata

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.gravitee.gateway.reactive.api.message.Message

attribute, attribute, attributeAsList, attributeNames, attributes, content, correlationId, error, error, headers, id, internalAttribute, internalAttribute, internalAttributeNames, internalAttributes, metadata, parentCorrelationId, removeAttribute, removeInternalAttribute, timestamp

Methods inherited from interface io.gravitee.gateway.reactive.api.tracing.message.TracingMessage

injectSpanContext, isTraceable

Method Details

headers

public HttpHeaders headers()

Description copied from interface: Message

Get the headers of the message.

Specified by:

headers in interface Message

Returns:

a read-write map of headers.

content

public DefaultMessage content(Buffer content)

Description copied from interface: Message

Set the content of the message.

Specified by:

content in interface Message

Parameters:

content - the buffer representing the content of the message.

Returns:

reference to itself for easily chain calls.

content

public DefaultMessage content(String content)

Description copied from interface: Message

Set the content of the message.

Specified by:

content in interface Message

Parameters:

content - the buffer representing the content of the message.

Returns:

reference to itself for easily chain calls.

ack

public void ack()

Description copied from interface: Message

MUST be called to acknowledge this message when it has been well-processed.

Specified by:

ack in interface Message

doOnEnd

public DefaultMessage doOnEnd(Runnable runnable)

Description copied from interface: TracingMessage

Behavior to apply when the underlying span will be ended.

Specified by:

doOnEnd in interface TracingMessage

end

public void end()

Description copied from interface: TracingMessage

Run the end behavior defined by TracingMessage.doOnEnd(Runnable)

Specified by:

end in interface TracingMessage

tracingAttributes

public Map<String,String> tracingAttributes()

Description copied from interface: TracingMessage

Return tracing attributes based on Semantic Conventions for Messaging

Specified by:

tracingAttributes in interface TracingMessage

Returns:

map of tracing attributes

addTracingAttribute

public void addTracingAttribute(String key,
 String value)

Description copied from interface: TracingMessage

Allow to add extra tracing attribute used to trace this message

Specified by:

addTracingAttribute in interface TracingMessage

Parameters:

key - the key of the span attribute

value - the value associated

builder

public static DefaultMessage.DefaultMessageBuilder builder()