public final class ArteryMessageSerializer extends SerializerWithStringManifest implements BaseSerializer
Constructor and Description |
---|
ArteryMessageSerializer(ExtendedActorSystem system) |
fromBinary, includeManifest
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
identifierFromConfig, SerializationIdentifiers
fromBinary, fromBinary, fromBinary, includeManifest
public ArteryMessageSerializer(ExtendedActorSystem system)
public static final boolean includeManifest()
public static final java.lang.String SerializationIdentifiers()
public static int identifierFromConfig()
protected abstract static void akka$serialization$BaseSerializer$_setter_$identifier_$eq(int x$1)
public int identifier()
SerializerWithStringManifest
identifier
in interface BaseSerializer
identifier
in interface Serializer
identifier
in class SerializerWithStringManifest
public ExtendedActorSystem system()
BaseSerializer
system
in interface BaseSerializer
public java.lang.String manifest(java.lang.Object o)
SerializerWithStringManifest
""
if manifest is not needed.manifest
in class SerializerWithStringManifest
o
- (undocumented)public byte[] toBinary(java.lang.Object o)
SerializerWithStringManifest
toBinary
in interface Serializer
toBinary
in class SerializerWithStringManifest
o
- (undocumented)public java.lang.Object fromBinary(byte[] bytes, java.lang.String manifest)
SerializerWithStringManifest
It's recommended to throw java.io.NotSerializableException
in fromBinary
if the manifest is unknown. This makes it possible to introduce new message
types and send them to nodes that don't know about them. This is typically
needed when performing rolling upgrades, i.e. running a cluster with mixed
versions for while. NotSerializableException
is treated as a transient
problem in the TCP based remoting layer. The problem will be logged
and message is dropped. Other exceptions will tear down the TCP connection
because it can be an indication of corrupt bytes from the underlying transport.
fromBinary
in class SerializerWithStringManifest
bytes
- (undocumented)manifest
- (undocumented)public ArteryControlFormats.Quarantined serializeQuarantined(Quarantined quarantined)
public Quarantined deserializeQuarantined(ArteryControlFormats.Quarantined quarantined)
public java.lang.String serializeActorRef(ActorRef ref)
public ActorRef deserializeActorRef(java.lang.String str)
public ArteryControlFormats.CompressionTableAdvertisement serializeActorRefCompressionAdvertisement(CompressionProtocol.ActorRefCompressionAdvertisement adv)
public CompressionProtocol.ActorRefCompressionAdvertisement deserializeActorRefCompressionAdvertisement(byte[] bytes)
public <T> ArteryControlFormats.CompressionTableAdvertisement serializeCompressionAdvertisement(CompressionProtocol.CompressionAdvertisement<T> adv, scala.Function1<T,java.lang.String> keySerializer)
public <T,U> U deserializeCompressionAdvertisement(byte[] bytes, scala.Function1<java.lang.String,T> keyDeserializer, scala.Function2<UniqueAddress,CompressionTable<T>,U> create)
public akka.protobuf.MessageLite serializeCompressionTableAdvertisementAck(UniqueAddress from, int version)
public java.lang.Object deserializeCompressionTableAdvertisementAck(byte[] bytes, scala.Function2<UniqueAddress,java.lang.Object,java.lang.Object> create)
public ArteryControlFormats.SystemMessageEnvelope serializeSystemMessageEnvelope(SystemMessageDelivery.SystemMessageEnvelope env)
public SystemMessageDelivery.SystemMessageEnvelope deserializeSystemMessageEnvelope(byte[] bytes)
public ArteryControlFormats.SystemMessageDeliveryAck serializeSystemMessageDeliveryAck(long seqNo, UniqueAddress from)
public java.lang.Object deserializeSystemMessageDeliveryAck(byte[] bytes, scala.Function2<java.lang.Object,UniqueAddress,java.lang.Object> create)
public akka.protobuf.MessageLite serializeWithAddress(UniqueAddress from)
public java.lang.Object deserializeWithFromAddress(byte[] bytes, scala.Function1<UniqueAddress,java.lang.Object> create)
public akka.protobuf.MessageLite serializeHandshakeReq(UniqueAddress from, Address to)
public OutboundHandshake.HandshakeReq deserializeHandshakeReq(byte[] bytes, scala.Function2<UniqueAddress,Address,OutboundHandshake.HandshakeReq> create)
public ArteryControlFormats.UniqueAddress serializeUniqueAddress(UniqueAddress address)
public UniqueAddress deserializeUniqueAddress(ArteryControlFormats.UniqueAddress address)
public ArteryControlFormats.Address serializeAddress(Address address)
public Address deserializeAddress(ArteryControlFormats.Address address)
public ArteryControlFormats.ArteryHeartbeatRsp serializeArteryHeartbeatRsp(long uid)
public RemoteWatcher.ArteryHeartbeatRsp deserializeArteryHeartbeatRsp(byte[] bytes, scala.Function1<java.lang.Object,RemoteWatcher.ArteryHeartbeatRsp> create)