@Test public void synchronizeSlaveServers_should_not_sync_unshared() throws Exception { final String slaveServerName = "SlaveServer"; JobMeta job1 = createJobMeta(); SlaveServer slaveServer1 = createSlaveServer( slaveServerName, true ); job1.setSlaveServers( Collections.singletonList( slaveServer1 ) ); spoonDelegates.jobs.addJob( job1 ); JobMeta job2 = createJobMeta(); SlaveServer slaveServer2 = createSlaveServer( slaveServerName, false ); job2.setSlaveServers( Collections.singletonList( slaveServer2 ) ); spoonDelegates.jobs.addJob( job2 ); slaveServer2.setHostname( AFTER_SYNC_VALUE ); sharedUtil.synchronizeSlaveServers( slaveServer2 ); assertThat( slaveServer1.getHostname(), equalTo( BEFORE_SYNC_VALUE ) ); }
public synchronized void synchronizeSlaveServers( SlaveServer slaveServer ) { synchronizeSlaveServers( slaveServer, slaveServer.getName() ); }
SharedObjectSyncUtil { public synchronized void synchronizeSlaveServers( SlaveServer slaveServer ) { synchronizeSlaveServers( slaveServer, slaveServer.getName() ); } }
SharedObjectSyncUtil { public synchronized void synchronizeSlaveServers( SlaveServer slaveServer ) { synchronizeSlaveServers( slaveServer, slaveServer.getName() ); } SharedObjectSyncUtil( Spoon spoon ); }
SharedObjectSyncUtil { public synchronized void synchronizeSlaveServers( SlaveServer slaveServer ) { synchronizeSlaveServers( slaveServer, slaveServer.getName() ); } SharedObjectSyncUtil( Spoon spoon ); synchronized void synchronizeConnections( DatabaseMeta database ); synchronized void synchronizeConnections( DatabaseMeta database, String originalName ); synchronized void synchronizeSlaveServers( SlaveServer slaveServer ); synchronized void synchronizeSlaveServers( SlaveServer slaveServer, String originalName ); synchronized void deleteSlaveServer( SlaveServer removed ); synchronized void deleteClusterSchema( ClusterSchema removed ); synchronized void deletePartitionSchema( PartitionSchema removed ); synchronized void reloadTransformationRepositoryObjects( boolean includeActive ); synchronized void reloadJobRepositoryObjects( boolean includeActive ); synchronized void reloadSharedObjects(); synchronized void synchronizeClusterSchemas( ClusterSchema clusterSchema ); synchronized void synchronizeClusterSchemas( ClusterSchema clusterSchema, String originalName ); synchronized void synchronizePartitionSchemas( PartitionSchema partitionSchema ); synchronized void synchronizePartitionSchemas( PartitionSchema partitionSchema, String originalName ); synchronized void synchronizeSteps( StepMeta step ); synchronized void synchronizeSteps( StepMeta step, String originalName ); }
SharedObjectSyncUtil { public synchronized void synchronizeSlaveServers( SlaveServer slaveServer ) { synchronizeSlaveServers( slaveServer, slaveServer.getName() ); } SharedObjectSyncUtil( Spoon spoon ); synchronized void synchronizeConnections( DatabaseMeta database ); synchronized void synchronizeConnections( DatabaseMeta database, String originalName ); synchronized void synchronizeSlaveServers( SlaveServer slaveServer ); synchronized void synchronizeSlaveServers( SlaveServer slaveServer, String originalName ); synchronized void deleteSlaveServer( SlaveServer removed ); synchronized void deleteClusterSchema( ClusterSchema removed ); synchronized void deletePartitionSchema( PartitionSchema removed ); synchronized void reloadTransformationRepositoryObjects( boolean includeActive ); synchronized void reloadJobRepositoryObjects( boolean includeActive ); synchronized void reloadSharedObjects(); synchronized void synchronizeClusterSchemas( ClusterSchema clusterSchema ); synchronized void synchronizeClusterSchemas( ClusterSchema clusterSchema, String originalName ); synchronized void synchronizePartitionSchemas( PartitionSchema partitionSchema ); synchronized void synchronizePartitionSchemas( PartitionSchema partitionSchema, String originalName ); synchronized void synchronizeSteps( StepMeta step ); synchronized void synchronizeSteps( StepMeta step, String originalName );  }