Package org.apache.pekko.remote

Class MessageSerializer

java.lang.Object

org.apache.pekko.remote.MessageSerializer

public class MessageSerializer
extends java.lang.Object

INTERNAL API

MessageSerializer is a helper for serializing and deserialize messages

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MessageSerializer.SerializationException

Constructor Summary

Constructors

Constructor	Description
MessageSerializer()

Method Summary

Modifier and Type	Method	Description
static java.lang.Object	deserialize(ExtendedActorSystem system, WireFormats.SerializedMessage messageProtocol)	Uses Pekko Serialization for the specified ActorSystem to transform the given MessageProtocol to a message
static java.lang.Object	deserializeForArtery(ExtendedActorSystem system, long originUid, Serialization serialization, int serializer, java.lang.String classManifest, org.apache.pekko.remote.artery.EnvelopeBuffer envelope)
static WireFormats.SerializedMessage	serialize(ExtendedActorSystem system, java.lang.Object message)	Uses Pekko Serialization for the specified ActorSystem to transform the given message to a MessageProtocol Throws NotSerializableException if serializer was not configured for the message type.
static void	serializeForArtery(Serialization serialization, OutboundEnvelope outboundEnvelope, HeaderBuilder headerBuilder, org.apache.pekko.remote.artery.EnvelopeBuffer envelope)

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageSerializer

public MessageSerializer()

Method Detail

deserialize

public static java.lang.Object deserialize(ExtendedActorSystem system,
                                           WireFormats.SerializedMessage messageProtocol)

Uses Pekko Serialization for the specified ActorSystem to transform the given MessageProtocol to a message

serialize

public static WireFormats.SerializedMessage serialize(ExtendedActorSystem system,
                                                      java.lang.Object message)

Uses Pekko Serialization for the specified ActorSystem to transform the given message to a MessageProtocol Throws NotSerializableException if serializer was not configured for the message type. Throws MessageSerializer.SerializationException if exception was thrown from toBinary of the serializer.

serializeForArtery

public static void serializeForArtery(Serialization serialization,
                                      OutboundEnvelope outboundEnvelope,
                                      HeaderBuilder headerBuilder,
                                      org.apache.pekko.remote.artery.EnvelopeBuffer envelope)

deserializeForArtery

public static java.lang.Object deserializeForArtery(ExtendedActorSystem system,
                                                    long originUid,
                                                    Serialization serialization,
                                                    int serializer,
                                                    java.lang.String classManifest,
                                                    org.apache.pekko.remote.artery.EnvelopeBuffer envelope)