raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Remove not needed ReplicatedDataSerializer

Browse source
This commit is contained in:
yiksanchan 2020-02-11 17:05:51 -08:00 • committed by GitHub
parent dcdaa5a0dd
commit 4fb21c380d
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 0 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-docs/src/test/scala/docs/ddata/protobuf/TwoPhaseSetSerializer2.scala
View file

@ -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}")