public class MessageSerializer
extends java.lang.Object
MessageSerializer is a helper for serializing and deserialize messages
Modifier and Type | Class and Description |
---|---|
static class |
MessageSerializer.SerializationException |
Constructor and Description |
---|
MessageSerializer() |
Modifier and Type | Method and Description |
---|---|
static java.lang.Object |
deserialize(ExtendedActorSystem system,
WireFormats.SerializedMessage messageProtocol)
Uses Akka 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,
EnvelopeBuffer envelope) |
static 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. |
static void |
serializeForArtery(Serialization serialization,
OutboundEnvelope outboundEnvelope,
HeaderBuilder headerBuilder,
EnvelopeBuffer envelope) |
public static java.lang.Object deserialize(ExtendedActorSystem system, WireFormats.SerializedMessage messageProtocol)
system
- (undocumented)messageProtocol
- (undocumented)public static 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 static void serializeForArtery(Serialization serialization, OutboundEnvelope outboundEnvelope, HeaderBuilder headerBuilder, EnvelopeBuffer envelope)
public static java.lang.Object deserializeForArtery(ExtendedActorSystem system, long originUid, Serialization serialization, int serializer, java.lang.String classManifest, EnvelopeBuffer envelope)