MessageSerializer$

java.lang.Object

org.apache.pekko.remote.MessageSerializer$

public class MessageSerializer$ extends Object

INTERNAL API

MessageSerializer is a helper for serializing and deserialize messages

Field Summary

Fields

Modifier and Type

Field

Description

static final MessageSerializer$

MODULE$

Static reference to the singleton instance of this Scala object.
Constructor Summary

Constructors

Constructor

Description

MessageSerializer$()
Method Summary

Modifier and Type

Method

Description

Object

deserialize(ExtendedActorSystem system, WireFormats.SerializedMessage messageProtocol)

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

Object

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

WireFormats.SerializedMessage

serialize(ExtendedActorSystem system, 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.

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

Field Details
- MODULE$
  
  public static final MessageSerializer$ MODULE$
  
  Static reference to the singleton instance of this Scala object.
Constructor Details
- MessageSerializer$
  
  public MessageSerializer$()
Method Details
- deserialize
  
  public Object deserialize(ExtendedActorSystem system, WireFormats.SerializedMessage messageProtocol)
  
  Uses Pekko Serialization for the specified ActorSystem to transform the given MessageProtocol to a message
- serialize
  
  public WireFormats.SerializedMessage serialize(ExtendedActorSystem system, 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 void serializeForArtery(Serialization serialization, OutboundEnvelope outboundEnvelope, HeaderBuilder headerBuilder, org.apache.pekko.remote.artery.EnvelopeBuffer envelope)
- deserializeForArtery
  
  public Object deserializeForArtery(ExtendedActorSystem system, long originUid, Serialization serialization, int serializer, String classManifest, org.apache.pekko.remote.artery.EnvelopeBuffer envelope)