From 4fb21c380de125f30c341bdde175c78bff85ce37 Mon Sep 17 00:00:00 2001 From: yiksanchan Date: Tue, 11 Feb 2020 17:05:51 -0800 Subject: [PATCH] Remove not needed ReplicatedDataSerializer --- .../scala/docs/ddata/protobuf/TwoPhaseSetSerializer2.scala | 3 --- 1 file changed, 3 deletions(-) diff --git a/akka-docs/src/test/scala/docs/ddata/protobuf/TwoPhaseSetSerializer2.scala b/akka-docs/src/test/scala/docs/ddata/protobuf/TwoPhaseSetSerializer2.scala index d6130a9f71..bf01681fa7 100644 --- a/akka-docs/src/test/scala/docs/ddata/protobuf/TwoPhaseSetSerializer2.scala +++ b/akka-docs/src/test/scala/docs/ddata/protobuf/TwoPhaseSetSerializer2.scala @@ -7,7 +7,6 @@ package docs.ddata.protobuf //#serializer import akka.actor.ExtendedActorSystem import akka.cluster.ddata.GSet -import akka.cluster.ddata.protobuf.ReplicatedDataSerializer import akka.cluster.ddata.protobuf.SerializationSupport import akka.serialization.Serializer import docs.ddata.TwoPhaseSet @@ -19,8 +18,6 @@ class TwoPhaseSetSerializer2(val system: ExtendedActorSystem) extends Serializer override def identifier = 99999 - val replicatedDataSerializer = new ReplicatedDataSerializer(system) - override def toBinary(obj: AnyRef): Array[Byte] = obj match { case m: TwoPhaseSet => twoPhaseSetToProto(m).toByteArray case _ => throw new IllegalArgumentException(s"Can't serialize object of type ${obj.getClass}")