public class MessageSerializer$
extends java.lang.Object
MessageSerializer is a helper for serializing and deserialize messages
Modifier and Type | Field and Description |
---|---|
static MessageSerializer$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
MessageSerializer$() |
Modifier and Type | Method and 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,
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,
EnvelopeBuffer envelope) |
public static final MessageSerializer$ MODULE$
public java.lang.Object deserialize(ExtendedActorSystem system, WireFormats.SerializedMessage messageProtocol)
system
- (undocumented)messageProtocol
- (undocumented)public WireFormats.SerializedMessage serialize(ExtendedActorSystem system, java.lang.Object message)
NotSerializableException
if serializer was not configured for the message type.
Throws MessageSerializer.SerializationException
if exception was thrown from toBinary
of the
serializer.system
- (undocumented)message
- (undocumented)public void serializeForArtery(Serialization serialization, OutboundEnvelope outboundEnvelope, HeaderBuilder headerBuilder, EnvelopeBuffer envelope)
public java.lang.Object deserializeForArtery(ExtendedActorSystem system, long originUid, Serialization serialization, int serializer, java.lang.String classManifest, EnvelopeBuffer envelope)