Package akka.remote

Class MessageSerializer$

java.lang.Object

akka.remote.MessageSerializer$

public class MessageSerializer$
extends java.lang.Object

INTERNAL API

MessageSerializer is a helper for serializing and deserialize messages

Field Summary

Fields

Modifier and Type	Field	Description
static 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
java.lang.Object	deserialize(ExtendedActorSystem system, WireFormats.SerializedMessage messageProtocol)	Uses Akka Serialization for the specified ActorSystem to transform the given MessageProtocol to a message
java.lang.Object	deserializeForArtery(ExtendedActorSystem system, long originUid, Serialization serialization, int serializer, java.lang.String classManifest, akka.remote.artery.EnvelopeBuffer envelope)
WireFormats.SerializedMessage	serialize(ExtendedActorSystem system, java.lang.Object message)	Uses Akka 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, akka.remote.artery.EnvelopeBuffer envelope)

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final MessageSerializer$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

MessageSerializer$

public MessageSerializer$()

Method Detail

deserialize

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

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

serialize

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

Uses Akka 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,
                               akka.remote.artery.EnvelopeBuffer envelope)

deserializeForArtery

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