Added more logging to Cluster's who to gossip selection process.
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
This commit is contained in:
parent
0bc0c237e6
commit
c16bd74073
1 changed files with 1 additions and 0 deletions
|
|
@ -795,6 +795,7 @@ class Cluster(system: ExtendedActorSystem) extends Extension { clusterNode ⇒
|
|||
* @return 'true' if it gossiped to a "deputy" member.
|
||||
*/
|
||||
private def gossipToRandomNodeOf(addresses: Iterable[Address]): Boolean = {
|
||||
log.debug("Cluster Node [{}] - Selecting random node to gossip to [{}]", remoteAddress, addresses.mkString(", "))
|
||||
if (addresses.isEmpty) false
|
||||
else {
|
||||
val peers = addresses filter (_ != remoteAddress) // filter out myself
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue