diff --git a/akka-cluster/src/main/scala/akka/cluster/ClusterHeartbeat.scala b/akka-cluster/src/main/scala/akka/cluster/ClusterHeartbeat.scala index 2c5f6070507..a2800cbfdd5 100644 --- a/akka-cluster/src/main/scala/akka/cluster/ClusterHeartbeat.scala +++ b/akka-cluster/src/main/scala/akka/cluster/ClusterHeartbeat.scala @@ -26,10 +26,14 @@ private[cluster] final class ClusterHeartbeatReceiver extends Actor with ActorLo // Important - don't use Cluster(context.system) in constructor because that would // cause deadlock. See startup sequence in ClusterDaemon. - lazy val selfHeartbeatRsp = HeartbeatRsp(Cluster(context.system).selfUniqueAddress) + lazy val cluster = Cluster(context.system) + lazy val selfHeartbeatRsp = HeartbeatRsp(cluster.selfUniqueAddress) + lazy val verboseHeartbeat = cluster.settings.Debug.VerboseHeartbeatLogging def receive = { - case Heartbeat(from) ⇒ sender() ! selfHeartbeatRsp + case Heartbeat(from) ⇒ + if (verboseHeartbeat) log.debug("Cluster Node [{}] - Heartbeat from [{}]", cluster.selfAddress, from) + sender() ! selfHeartbeatRsp } } diff --git a/akka-remote/src/main/scala/akka/remote/transport/AkkaProtocolTransport.scala b/akka-remote/src/main/scala/akka/remote/transport/AkkaProtocolTransport.scala index 4a3ddd26380..487097d7be7 100644 --- a/akka-remote/src/main/scala/akka/remote/transport/AkkaProtocolTransport.scala +++ b/akka-remote/src/main/scala/akka/remote/transport/AkkaProtocolTransport.scala @@ -573,7 +573,7 @@ private[transport] class ProtocolStateActor( }) wrappedHandle.disassociate(disassociationReason(reason), log) - case StopEvent(reason, _, AssociatedWaitHandler(handlerFuture, wrappedHandle, queue)) ⇒ + case StopEvent(reason, _, AssociatedWaitHandler(handlerFuture, wrappedHandle, _)) ⇒ // Invalidate exposed but still unfinished promise. The underlying association disappeared, so after // registration immediately signal a disassociate val disassociateNotification = reason match {