org.springframework.cloud.stream.binder

Class MessageSerializationUtils

java.lang.Object

org.springframework.cloud.stream.binder.MessageSerializationUtils

public abstract class MessageSerializationUtils
extends Object

Utility class for serializing and de-serializing the message payload.

Author:

Soby Chacko, Vinicius Carvalho

Constructor Summary

Constructors

Constructor and Description
MessageSerializationUtils()

Method Summary

Modifier and Type	Method and Description
static MessageValues	deserializePayload(MessageValues messageValues, org.springframework.messaging.converter.ContentTypeResolver contentTypeResolver) De-serialize the message payload if necessary.
static MessageValues	serializePayload(org.springframework.messaging.Message<?> message) Serialize the message payload unless it is a byte array.

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageSerializationUtils

public MessageSerializationUtils()

Method Detail

serializePayload

public static MessageValues serializePayload(org.springframework.messaging.Message<?> message)

Serialize the message payload unless it is a byte array.

Parameters:

message - the message with the payload to serialize

Returns:

the Message with teh serialized payload

deserializePayload

public static MessageValues deserializePayload(MessageValues messageValues,
                                               org.springframework.messaging.converter.ContentTypeResolver contentTypeResolver)

De-serialize the message payload if necessary.

Parameters:

messageValues - message with the payload to deserialize

contentTypeResolver - used for resolving the mime type.

Returns:

Deserialized Message.