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

treat serialization (toBinary) exception of remote message as transient error, #21343

Browse source
This commit is contained in:
Patrik Nordwall 2016-09-02 11:05:00 +02:00
parent ee116dcdab
commit fa084fc5ce
2 changed files with 27 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

5
akka-remote/src/main/scala/akka/remote/Endpoint.scala
View file

@ -803,7 +803,10 @@ private[remote] class EndpointWriter(
}
} catch {
case e: NotSerializableException ⇒
log.error(e, "Transient association error (association remains live)")
log.error(e, "Serializer not defined for message type []. Transient association error (association remains live)", s.message.getClass)
true
case e: MessageSerializer.SerializationException ⇒
log.error(e, "{} Transient association error (association remains live)", e.getMessage)
true
case e: EndpointException ⇒
publishAndThrow(e, Logging.ErrorLevel)