org.springframework.cloud.stream.binder

Class EmbeddedHeadersMessageConverter

java.lang.Object

org.springframework.cloud.stream.binder.EmbeddedHeadersMessageConverter

public class EmbeddedHeadersMessageConverter
extends Object

Encodes requested headers into payload with format 0xff, n(1), [ [lenHdr(1), hdr, lenValue(4), value] ... ]. The 0xff indicates this new format; n is number of headers (max 255); for each header, the name length (1 byte) is followed by the name, followed by the value length (int) followed by the value (json).

Previously, there was no leading 0xff; the value length was 1 byte and only String header values were supported (no JSON conversion).

Author:

Eric Bottard, Gary Russell

Constructor Summary

Constructors

Constructor and Description
EmbeddedHeadersMessageConverter()

Method Summary

Modifier and Type	Method and Description
static String	decodeExceptionMessage(org.springframework.messaging.Message<?> requestMessage)
byte[]	embedHeaders(MessageValues original, String... headers) Return a new message where some of the original headers of original have been embedded into the new message payload.
MessageValues	extractHeaders(org.springframework.messaging.Message<byte[]> message, boolean copyRequestHeaders) Return a message where headers, that were originally embedded into the payload, have been promoted back to actual headers.

Methods inherited from class java.lang.Object

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

Constructor Detail

EmbeddedHeadersMessageConverter

public EmbeddedHeadersMessageConverter()

Method Detail

decodeExceptionMessage

public static String decodeExceptionMessage(org.springframework.messaging.Message<?> requestMessage)

embedHeaders

public byte[] embedHeaders(MessageValues original,
                           String... headers)
                    throws Exception

Return a new message where some of the original headers of original have been embedded into the new message payload.

Throws:

Exception

extractHeaders

public MessageValues extractHeaders(org.springframework.messaging.Message<byte[]> message,
                                    boolean copyRequestHeaders)
                             throws Exception

Return a message where headers, that were originally embedded into the payload, have been promoted back to actual headers. The new payload is now the original payload.

Parameters:

message - the message to extract headers

copyRequestHeaders - boolean value to specify if original headers should be copied

Throws:

Exception