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

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, org.springframework.integration.codec.Codec codec) De-serialize the message payload if necessary.
static MessageValues	serializePayload(org.springframework.messaging.Message<?> message, org.springframework.integration.codec.Codec codec) Serialize the message payload unless it is a byte array.
static byte[]	serializePayload(Object originalPayload, org.springframework.integration.codec.Codec codec) Serialize the payload object if it is not 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,
                                             org.springframework.integration.codec.Codec codec)

Serialize the message payload unless it is a byte array.

Parameters:

message - the message with the payload to serialize

codec - the codec used for serialization

Returns:

the Message with teh serialized payload

serializePayload

public static byte[] serializePayload(Object originalPayload,
                                      org.springframework.integration.codec.Codec codec)

Serialize the payload object if it is not a byte array.

Parameters:

originalPayload - the payload to serialize

codec - the codec used for serialization

Returns:

the serialized byte array or the original payload if it is already a byte array

Throws:

org.springframework.core.serializer.support.SerializationFailedException - thrown when serialization failed

deserializePayload

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

De-serialize the message payload if necessary.

Parameters:

messageValues - message with the payload to deserialize

contentTypeResolver - used for resolving the mime type.

codec - used for deserialization

Returns:

Deserialized Message.