diff --git a/akka-remote/src/main/scala/akka/remote/artery/Codecs.scala b/akka-remote/src/main/scala/akka/remote/artery/Codecs.scala index 49d4c6bdd8..03577e289d 100644 --- a/akka-remote/src/main/scala/akka/remote/artery/Codecs.scala +++ b/akka-remote/src/main/scala/akka/remote/artery/Codecs.scala @@ -76,7 +76,7 @@ private[remote] class Encoder( throw e case _ if e.isInstanceOf[java.nio.BufferOverflowException] ⇒ val reason = new OversizedPayloadException(s"Discarding oversized payload sent to ${send.recipient}: max allowed size ${envelope.byteBuffer.limit()} bytes. Message type [${send.message.getClass.getName}].") - log.error(reason, "Transient association error (association remains live)") + log.error(reason, "Failed to serialize oversized message [{}].", send.message.getClass.getName) pull(in) case _ ⇒ log.error(e, "Failed to serialize message [{}].", send.message.getClass.getName) diff --git a/akka-remote/src/test/scala/akka/remote/artery/RemoteMessageSerializationSpec.scala b/akka-remote/src/test/scala/akka/remote/artery/RemoteMessageSerializationSpec.scala index d0ed9e5a93..77fdca9792 100644 --- a/akka-remote/src/test/scala/akka/remote/artery/RemoteMessageSerializationSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/artery/RemoteMessageSerializationSpec.scala @@ -55,7 +55,7 @@ class RemoteMessageSerializationSpec extends ArteryMultiNodeSpec(""" "drop sent messages over payload size" in { val oversized = byteStringOfSize(maxPayloadBytes + 1) - EventFilter[OversizedPayloadException](pattern = ".*Discarding oversized payload sent.*", occurrences = 1).intercept { + EventFilter[OversizedPayloadException](start = "Failed to serialize oversized message", occurrences = 1).intercept { verifySend(oversized) { expectNoMsg(1.second) // No AssocitionErrorEvent should be published }