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

adjust oversized error message

Browse source
This commit is contained in:
Patrik Nordwall 2016-06-23 19:19:59 +02:00
parent a021eb5ff4
commit 9ffe211546
2 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-remote/src/main/scala/akka/remote/artery/Codecs.scala
View file

@ -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)

2
akka-remote/src/test/scala/akka/remote/artery/RemoteMessageSerializationSpec.scala
View file

@ -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
}