DefaultMasterChooserManager extends AbstractCurrentPeerMasterMetaObserver implements MasterChooserManager { @Override protected void addShard(String clusterId, String shardId) { try { logger.info("[addShard]{}, {}", clusterId, shardId); CurrentMasterChooser currentMasterChooser = new CurrentMasterChooser(clusterId, shardId, dcMetaCache, currentMetaManager, chooseCommandFactory, executors, peerMasterChooseExecutor, scheduled); currentMasterChooser.start(); MasterChooser peerMasterChooser = new PeerMasterChooser(clusterId, shardId, dcMetaCache, currentMetaManager, chooseCommandFactory, executors, peerMasterChooseExecutor, scheduled); peerMasterChooser.start(); registerJob(clusterId, shardId, currentMasterChooser); registerJob(clusterId, shardId, peerMasterChooser); } catch (Exception e) { logger.error("[addShard]{}, {}", clusterId, shardId, e); } }    }
@Test public void testAddShard() { }