+ ///
+ /*
+ * syncController.performAction(SyncActions.SYNCHRONIZE);
+ *
+ * while (syncController.getState() == SynchronizerState.PERFORMING_SYNCHRONIZATION) {
+ * Thread.sleep(1000); }
+ *
+ * syncController.shutdown();
+ *
+ * } catch (Exception exc) { exc.printStackTrace(); System.out.println(
+ * "Error: failed to sync with message = " + exc.getMessage()); } }
+ *
+ * /** Do cross entity reference sync.
+ *//*
+ * public void doCrossEntityReferenceSync() { try {
+ *
+ * ActiveInventoryAdapter aaiAdapter = new ActiveInventoryAdapter(new OxmModelLoader(), new
+ * RestClientBuilder());
+ *
+ * RestClientBuilder clientBuilder = new RestClientBuilder(); clientBuilder.setUseHttps(false);
+ *
+ * RestfulDataAccessor nonCachingRestProvider = new RestfulDataAccessor(clientBuilder);
+ * ElasticSearchConfig esConfig = ElasticSearchConfig.getConfig();
+ *
+ * ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider,esConfig);
+ *
+ * SyncController syncController = new SyncControllerImpl("crossEntityRefSyncController");
+ *
+ * CrossEntityReferenceSynchronizer cers = new
+ * CrossEntityReferenceSynchronizer("entitysearchindex-localhost",
+ * ActiveInventoryConfig.getConfig()); cers.setAaiDataProvider(aaiAdapter);
+ * cers.setEsDataProvider(esAdapter); syncController.registerEntitySynchronizer(cers);
+ *
+ * ViewInspectEntitySynchronizer ses = new
+ * ViewInspectEntitySynchronizer("entitysearchindex-localhost");
+ * ses.setAaiDataProvider(aaiAdapter); ses.setEsDataProvider(esAdapter);
+ * syncController.registerEntitySynchronizer(ses);
+ *
+ * ElasticSearchConfig config = ElasticSearchConfig.getConfig();
+ *
+ * IndexIntegrityValidator entitySearchIndexValidator = new IndexIntegrityValidator(
+ * nonCachingRestProvider, config.getIndexName(), config.getType(), config.getIpAddress(),
+ * config.getHttpPort(), config.buildElasticSearchTableConfig());
+ *
+ * syncController.registerIndexValidator(entitySearchIndexValidator);
+ *
+ * ////
+ *
+ * IndexCleaner index1Cleaner = new ElasticSearchIndexCleaner(nonCachingRestProvider,
+ * config.getIndexName(), config.getType(), config.getIpAddress(), config.getHttpPort(), 5,
+ * 5000);
+ *
+ * syncController.registerIndexCleaner(index1Cleaner);
+ *
+ * ///
+ *
+ * syncController.performAction(SyncActions.SYNCHRONIZE);
+ *
+ * while (syncController.getState() == SynchronizerState.PERFORMING_SYNCHRONIZATION) {
+ * Thread.sleep(1000); }
+ *
+ * syncController.shutdown();
+ *
+ * } catch (Exception exc) { exc.printStackTrace(); System.out.println(
+ * "Error: Failed to sync with message = " + exc.getMessage()); } }
+ *
+ * /** Do suggestion entitysync.
+ *//*
+ * public void doSuggestionEntitySync() { try { ActiveInventoryAdapter aaiAdapter = new
+ * ActiveInventoryAdapter(new OxmModelLoader(), new RestClientBuilder());