ElasticSearchConfig esConfig = ElasticSearchConfig.getConfig();
- ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider,esConfig);
+ ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider, esConfig);
IndexIntegrityValidator entityCounterHistoryValidator =
RestfulDataAccessor nonCachingRestProvider = new RestfulDataAccessor(clientBuilder);
ElasticSearchConfig esConfig = ElasticSearchConfig.getConfig();
- ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider,esConfig);
+ ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider, esConfig);
IndexIntegrityValidator entitySearchIndexValidator =
new IndexIntegrityValidator(nonCachingRestProvider, esConfig.getIndexName(),
*/
public void doSearchableEntitysync() {
try {
-
+
ActiveInventoryAdapter aaiAdapter = new ActiveInventoryAdapter(new RestClientBuilder());
RestfulDataAccessor nonCachingRestProvider = new RestfulDataAccessor(clientBuilder);
ElasticSearchConfig esConfig = ElasticSearchConfig.getConfig();
- ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider,esConfig);
+ ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider, esConfig);
//////
-
+
SyncController syncController = new SyncController("searchtableEntityTestController");
SearchableEntitySynchronizer ses =
*/
public void doCrossEntityReferenceSync() {
try {
-
+
ActiveInventoryAdapter aaiAdapter = new ActiveInventoryAdapter(new RestClientBuilder());
RestfulDataAccessor nonCachingRestProvider = new RestfulDataAccessor(clientBuilder);
ElasticSearchConfig esConfig = ElasticSearchConfig.getConfig();
- ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider,esConfig);
+ ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider, esConfig);
SyncController syncController = new SyncController("crossEntityRefSyncController");
- CrossEntityReferenceSynchronizer cers =
- new CrossEntityReferenceSynchronizer("entitysearchindex-localhost", ActiveInventoryConfig.getConfig());
+ CrossEntityReferenceSynchronizer cers = new CrossEntityReferenceSynchronizer(
+ "entitysearchindex-localhost", ActiveInventoryConfig.getConfig());
cers.setAaiDataProvider(aaiAdapter);
cers.setEsDataProvider(esAdapter);
syncController.registerEntitySynchronizer(cers);
*/
public void doSuggestionEntitySync() {
try {
-
+
ActiveInventoryAdapter aaiAdapter = new ActiveInventoryAdapter(new RestClientBuilder());
RestfulDataAccessor nonCachingRestProvider = new RestfulDataAccessor(clientBuilder);
ElasticSearchConfig esConfig = ElasticSearchConfig.getConfig();
- ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider,esConfig);
-
+ ElasticSearchAdapter esAdapter = new ElasticSearchAdapter(nonCachingRestProvider, esConfig);
+
SyncController syncController = new SyncController("suggestionEntityTestController");
AutosuggestionSynchronizer ses =
System.out.println("Error: failed to sync with message = " + exc.getMessage());
}
}
-
+
/*
* Do no op sync.
*/