Skip to content

Commit

Permalink
Merge remote-tracking branch 'origin/3.3' into 3.4
Browse files Browse the repository at this point in the history
  • Loading branch information
martinfurmanski committed Dec 5, 2017
2 parents 86fc858 + 982bea5 commit 14d511c
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -336,16 +336,16 @@ private synchronized void refreshTopology() throws InterruptedException
private void refreshCoreTopology() throws InterruptedException
{
waitOnHazelcastInstanceCreation();

CoreTopology newCoreTopology = getCoreTopology( hazelcastInstance, config, log );
TopologyDifference difference = coreTopology.difference( newCoreTopology );
coreTopology = newCoreTopology;

if ( difference.hasChanges() )
{
log.info( "Core topology changed %s", difference );
listenerService.notifyListeners( coreTopology );
}

this.coreTopology = newCoreTopology;
listenerService.notifyListeners( this.coreTopology );

}

private void refreshReadReplicaTopology() throws InterruptedException
Expand Down

0 comments on commit 14d511c

Please sign in to comment.