...
|
...
|
@@ -26,6 +26,7 @@ public class IndexRebuildListenerMgr { |
|
|
IYohoIndexRebuildListener listener = listeners.get(yohoIndexName);
|
|
|
if (listener != null) {
|
|
|
try {
|
|
|
INDEX_REBUILD_LOG.info("Execute before rebuild for {}.", yohoIndexName);
|
|
|
listener.beforeRebuild();
|
|
|
} catch (Exception e) {
|
|
|
INDEX_REBUILD_LOG.error("Execute before rebuild index " + yohoIndexName + " failed.", e);
|
...
|
...
|
@@ -37,6 +38,7 @@ public class IndexRebuildListenerMgr { |
|
|
IYohoIndexRebuildListener listener = listeners.get(yohoIndexName);
|
|
|
if (listener != null) {
|
|
|
try {
|
|
|
INDEX_REBUILD_LOG.info("Execute after rebuild for {}.", yohoIndexName);
|
|
|
listener.afterRebuild(exception);
|
|
|
} catch (Exception e) {
|
|
|
INDEX_REBUILD_LOG.error("Execute after rebuild index " + yohoIndexName + " failed.", e);
|
...
|
...
|
|