honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

try catch in post listeners

This commit is contained in:
Ivannikov Kirill 2015-09-02 18:18:49 +05:00
parent 30b6a29e0b
commit 39fad8c374
1 changed files with 25 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
core/src/main/java/org/elasticsearch/index/indexing/ShardIndexingService.java
View File

@ -117,7 +117,11 @@ public class ShardIndexingService extends AbstractIndexShardComponent {
typeStats.indexCurrent.dec(); typeStats.indexCurrent.dec();
slowLog.postCreate(create, took); slowLog.postCreate(create, took);
for (IndexingOperationListener listener : listeners) { for (IndexingOperationListener listener : listeners) {
listener.postCreate(create); try {
listener.postCreate(create);
} catch (Exception e) {
logger.warn("postCreate listener [{}] failed", e, listener);
}
} }
} }
@ -138,7 +142,11 @@ public class ShardIndexingService extends AbstractIndexShardComponent {
public void postIndexUnderLock(Engine.Index index) { public void postIndexUnderLock(Engine.Index index) {
for (IndexingOperationListener listener : listeners) { for (IndexingOperationListener listener : listeners) {
listener.postIndexUnderLock(index); try {
listener.postIndexUnderLock(index);
} catch (Exception e) {
logger.warn("postIndexUnderLock listener [{}] failed", e, listener);
}
} }
} }
@ -151,7 +159,11 @@ public class ShardIndexingService extends AbstractIndexShardComponent {
typeStats.indexCurrent.dec(); typeStats.indexCurrent.dec();
slowLog.postIndex(index, took); slowLog.postIndex(index, took);
for (IndexingOperationListener listener : listeners) { for (IndexingOperationListener listener : listeners) {
listener.postIndex(index); try {
listener.postIndex(index);
} catch (Exception e) {
logger.warn("postIndex listener [{}] failed", e, listener);
}
} }
} }
@ -174,7 +186,11 @@ public class ShardIndexingService extends AbstractIndexShardComponent {
public void postDeleteUnderLock(Engine.Delete delete) { public void postDeleteUnderLock(Engine.Delete delete) {
for (IndexingOperationListener listener : listeners) { for (IndexingOperationListener listener : listeners) {
listener.postDeleteUnderLock(delete); try {
listener.postDeleteUnderLock(delete);
} catch (Exception e) {
logger.warn("postDeleteUnderLock listener [{}] failed", e, listener);
}
} }
} }
@ -186,6 +202,11 @@ public class ShardIndexingService extends AbstractIndexShardComponent {
typeStats.deleteMetric.inc(took); typeStats.deleteMetric.inc(took);
typeStats.deleteCurrent.dec(); typeStats.deleteCurrent.dec();
for (IndexingOperationListener listener : listeners) { for (IndexingOperationListener listener : listeners) {
try {
listener.postDelete(delete);
} catch (Exception e) {
logger.warn("postDelete listener [{}] failed", e, listener);
}
listener.postDelete(delete); listener.postDelete(delete);
} }
} }