From ec0d6a777866a64b20fa91bcf821ab1d7d89f540 Mon Sep 17 00:00:00 2001 From: Patrik Nordwall Date: Fri, 24 Jan 2025 15:52:12 +0100 Subject: [PATCH] adjust test --- .../projection/grpc/internal/EventProducerServiceSpec.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/akka-projection-grpc-tests/src/test/scala/akka/projection/grpc/internal/EventProducerServiceSpec.scala b/akka-projection-grpc-tests/src/test/scala/akka/projection/grpc/internal/EventProducerServiceSpec.scala index f561484f6..225dbe8e9 100644 --- a/akka-projection-grpc-tests/src/test/scala/akka/projection/grpc/internal/EventProducerServiceSpec.scala +++ b/akka-projection-grpc-tests/src/test/scala/akka/projection/grpc/internal/EventProducerServiceSpec.scala @@ -613,14 +613,14 @@ class EventProducerServiceSpec protoAnySerialization.deserialize(out1.getEvent.metadata.get) shouldBe ReplicatedEventMetadata( originReplica = ReplicaId.empty, originSequenceNr = env1.sequenceNr, - version = VersionVector(env1.persistenceId, env1.sequenceNr), + version = VersionVector(ReplicaId.empty.id, env1.sequenceNr), concurrent = false) val out2 = probe.expectNext() protoAnySerialization.deserialize(out2.getEvent.metadata.get) shouldBe ReplicatedEventMetadata( originReplica = ReplicaId.empty, originSequenceNr = env2.sequenceNr, - version = VersionVector(env2.persistenceId, env2.sequenceNr), + version = VersionVector(ReplicaId.empty.id, env2.sequenceNr), concurrent = false) }