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:
Patrik Nordwall 2020-02-12 16:28:48 +01:00 • committed by GitHub
commit 9b5f84286b
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 //#serializer
import akka.actor.ExtendedActorSystem import akka.actor.ExtendedActorSystem
import akka.cluster.ddata.GSet import akka.cluster.ddata.GSet
import akka.cluster.ddata.protobuf.ReplicatedDataSerializer
import akka.cluster.ddata.protobuf.SerializationSupport import akka.cluster.ddata.protobuf.SerializationSupport
import akka.serialization.Serializer import akka.serialization.Serializer
import docs.ddata.TwoPhaseSet import docs.ddata.TwoPhaseSet
@ -19,8 +18,6 @@ class TwoPhaseSetSerializer2(val system: ExtendedActorSystem) extends Serializer
override def identifier = 99999 override def identifier = 99999
val replicatedDataSerializer = new ReplicatedDataSerializer(system)
override def toBinary(obj: AnyRef): Array[Byte] = obj match { override def toBinary(obj: AnyRef): Array[Byte] = obj match {
case m: TwoPhaseSet => twoPhaseSetToProto(m).toByteArray case m: TwoPhaseSet => twoPhaseSetToProto(m).toByteArray
case _ => throw new IllegalArgumentException(s"Can't serialize object of type ${obj.getClass}") case _ => throw new IllegalArgumentException(s"Can't serialize object of type ${obj.getClass}")