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

Giving all remote messages their own uuid, reusing actorInfo.uuid for futures, closing ticket 580

Browse source
This commit is contained in:
Viktor Klang 2010-12-20 11:00:55 +01:00
parent dbd8a60faf
commit 5624e6d3aa
2 changed files with 31 additions and 27 deletions
Download patch file Download diff file Expand all files Collapse all files

5
akka-remote/src/main/scala/akka/serialization/SerializationProtocol.scala
View file

@ -295,7 +295,10 @@ object RemoteActorSerialization {
}
val actorInfo = actorInfoBuilder.build
val messageBuilder = RemoteMessageProtocol.newBuilder
.setUuid(uuidProtocol)
.setUuid({
val messageUuid = newUuid
UuidProtocol.newBuilder.setHigh(messageUuid.getTime).setLow(messageUuid.getClockSeqAndNode).build
})
.setActorInfo(actorInfo)
.setOneWay(isOneWay)