diff --git a/akka-remote/src/main/scala/akka/remote/Endpoint.scala b/akka-remote/src/main/scala/akka/remote/Endpoint.scala index 58510e17ea..fbcf16a2c1 100644 --- a/akka-remote/src/main/scala/akka/remote/Endpoint.scala +++ b/akka-remote/src/main/scala/akka/remote/Endpoint.scala @@ -227,8 +227,9 @@ private[remote] class ReliableDeliverySupervisor( var resendBuffer: AckedSendBuffer[Send] = _ var seqCounter: Long = _ - def reset() { + def reset(): Unit = { resendBuffer = new AckedSendBuffer[Send](settings.SysMsgBufferSize) + bufferWasInUse = false seqCounter = 0L bailoutAt = None }