Package org.apache.pekko.serialization

Class JavaSerializer

java.lang.Object
org.apache.pekko.serialization.JavaSerializer
All Implemented Interfaces:
BaseSerializer, Serializer
public class JavaSerializer extends Object implements BaseSerializer
This Serializer uses standard Java Serialization

  • Constructor Details

  • Method Details

    • currentSystem

      public static JavaSerializer.CurrentSystem currentSystem()
      This holds a reference to the current ActorSystem (the surrounding context) during serialization and deserialization.

      If you are using Serializers yourself, outside of SerializationExtension, you'll need to surround the serialization/deserialization with:

      JavaSerializer.currentSystem.withValue(system) { ...code... }

      or

      JavaSerializer.currentSystem.withValue(system, callable)

    • identifier

      public int identifier()
      Description copied from interface: BaseSerializer
      Globally unique serialization identifier configured in the reference.conf.

      See pekko.serialization.Serializer.identifier.

      Specified by:
      identifier in interface BaseSerializer
      Specified by:
      identifier in interface Serializer

    • org$apache$pekko$serialization$BaseSerializer$_setter_$identifier_$eq

      protected void org$apache$pekko$serialization$BaseSerializer$_setter_$identifier_$eq(int x$1)
      Description copied from interface: BaseSerializer
      Globally unique serialization identifier configured in the reference.conf.

      See pekko.serialization.Serializer.identifier.

      Specified by:
      org$apache$pekko$serialization$BaseSerializer$_setter_$identifier_$eq in interface BaseSerializer

    • system

      public ExtendedActorSystem system()
      Description copied from interface: BaseSerializer
      Actor system which is required by most serializer implementations.
      Specified by:
      system in interface BaseSerializer

    • includeManifest

      public boolean includeManifest()
      Description copied from interface: Serializer
      Returns whether this serializer needs a manifest in the fromBinary method
      Specified by:
      includeManifest in interface Serializer

    • toBinary

      public byte[] toBinary(Object o)
      Description copied from interface: Serializer
      Serializes the given object into an Array of Byte.

      Note that the array must not be mutated by the serializer after it has been returned.

      Specified by:
      toBinary in interface Serializer

    • fromBinary

      public Object fromBinary(byte[] bytes, scala.Option<Class<?>> clazz) throws NotSerializableException
      Description copied from interface: Serializer
      Produces an object from an array of bytes, with an optional type-hint; the class should be loaded using ActorSystem.dynamicAccess.
      Specified by:
      fromBinary in interface Serializer
      Throws:
      NotSerializableException