catch indices lifecycle failures and log them

make sure we catch index/shard lifecycle failures, and properly log them

src/main/java/org/elasticsearch/indices/InternalIndicesLifecycle.java

@@ -53,61 +53,101 @@ public class InternalIndicesLifecycle extends AbstractComponent implements Indic
 
     public void shardRoutingChanged(IndexShard indexShard, @Nullable ShardRouting oldRouting, ShardRouting newRouting) {
         for (Listener listener : listeners) {
+            try {
                 listener.shardRoutingChanged(indexShard, oldRouting, newRouting);
+            } catch (Throwable t) {
+                logger.warn("{} failed to invoke shard touring changed callback", t, indexShard.shardId());
+            }
         }
     }
 
     public void beforeIndexCreated(Index index) {
         for (Listener listener : listeners) {
+            try {
                 listener.beforeIndexCreated(index);
+            } catch (Throwable t) {
+                logger.warn("[{}] failed to invoke before index created callback", t, index.name());
+            }
         }
     }
 
     public void afterIndexCreated(IndexService indexService) {
         for (Listener listener : listeners) {
+            try {
                 listener.afterIndexCreated(indexService);
+            } catch (Throwable t) {
+                logger.warn("[{}] failed to invoke after index created callback", t, indexService.index().name());
+            }
         }
     }
 
     public void beforeIndexShardCreated(ShardId shardId) {
         for (Listener listener : listeners) {
+            try {
                 listener.beforeIndexShardCreated(shardId);
+            } catch (Throwable t) {
+                logger.warn("{} failed to invoke before shard created callback", t, shardId);
+            }
         }
     }
 
     public void afterIndexShardCreated(IndexShard indexShard) {
         for (Listener listener : listeners) {
+            try {
                 listener.afterIndexShardCreated(indexShard);
+            } catch (Throwable t) {
+                logger.warn("{} failed to invoke after shard created callback", t, indexShard.shardId());
+            }
         }
     }
 
     public void afterIndexShardStarted(IndexShard indexShard) {
         for (Listener listener : listeners) {
+            try {
                 listener.afterIndexShardStarted(indexShard);
+            } catch (Throwable t) {
+                logger.warn("{} failed to invoke after shard started callback", t, indexShard.shardId());
+            }
         }
     }
 
     public void beforeIndexClosed(IndexService indexService) {
         for (Listener listener : listeners) {
+            try {
                 listener.beforeIndexClosed(indexService);
+            } catch (Throwable t) {
+                logger.warn("[{}] failed to invoke before index closed callback", t, indexService.index().name());
+            }
         }
     }
 
     public void afterIndexClosed(Index index) {
         for (Listener listener : listeners) {
+            try {
                 listener.afterIndexClosed(index);
+            } catch (Throwable t) {
+                logger.warn("[{}] failed to invoke after index closed callback", t, index.name());
+            }
         }
     }
 
     public void beforeIndexShardClosed(ShardId shardId, @Nullable IndexShard indexShard) {
         for (Listener listener : listeners) {
+            try {
                 listener.beforeIndexShardClosed(shardId, indexShard);
+            } catch (Throwable t) {
+                logger.warn("{} failed to invoke before shard closed callback", t, shardId);
+            }
         }
     }
 
     public void afterIndexShardClosed(ShardId shardId) {
         for (Listener listener : listeners) {
+            try {
                 listener.afterIndexShardClosed(shardId);
+            } catch (Throwable t) {
+                logger.warn("{} failed to invoke after shard closed callback", t, shardId);
+            }
         }
     }
 }