@@ -354,7 +354,7 @@ public void putSynonymsSet(
354354 ? UpdateSynonymsResultStatus .CREATED
355355 : UpdateSynonymsResultStatus .UPDATED ;
356356
357- maybeReloadAnalyzers (synonymSetId , refresh , false , updateSynonymsResultStatus , bulkInsertResponseListener );
357+ checkIndexSearchableAndReloadAnalyzers (synonymSetId , refresh , false , updateSynonymsResultStatus , bulkInsertResponseListener );
358358 })
359359 );
360360 }));
@@ -424,7 +424,7 @@ private void indexSynonymRule(
424424 ? UpdateSynonymsResultStatus .CREATED
425425 : UpdateSynonymsResultStatus .UPDATED ;
426426
427- maybeReloadAnalyzers (synonymsSetId , refresh , false , updateStatus , l2 );
427+ checkIndexSearchableAndReloadAnalyzers (synonymsSetId , refresh , false , updateStatus , l2 );
428428 }));
429429 }
430430
@@ -468,7 +468,11 @@ public void deleteSynonymRule(
468468 return ;
469469 }
470470
471- maybeReloadAnalyzers (synonymsSetId , refresh , false , UpdateSynonymsResultStatus .DELETED , listener );
471+ if (refresh ) {
472+ reloadAnalyzers (synonymsSetId , false , UpdateSynonymsResultStatus .DELETED , listener );
473+ } else {
474+ listener .onResponse (new SynonymsReloadResult (UpdateSynonymsResultStatus .DELETED , null ));
475+ }
472476 }));
473477 }
474478
@@ -526,7 +530,7 @@ private void deleteSynonymsSetObjects(String synonymSetId, ActionListener<BulkBy
526530 public void deleteSynonymsSet (String synonymSetId , ActionListener <AcknowledgedResponse > listener ) {
527531
528532 // Previews reloading the resource to understand its usage on indices
529- maybeReloadAnalyzers (synonymSetId , true , true , null , listener .delegateFailure ((reloadListener , reloadResult ) -> {
533+ reloadAnalyzers (synonymSetId , true , null , listener .delegateFailure ((reloadListener , reloadResult ) -> {
530534 Map <String , ReloadAnalyzersResponse .ReloadDetails > reloadDetails = reloadResult .reloadAnalyzersResponse .getReloadDetails ();
531535 if (reloadDetails .isEmpty () == false ) {
532536 Set <String > indices = reloadDetails .entrySet ()
@@ -566,7 +570,7 @@ public void deleteSynonymsSet(String synonymSetId, ActionListener<AcknowledgedRe
566570 }));
567571 }
568572
569- private <T > void maybeReloadAnalyzers (
573+ private <T > void checkIndexSearchableAndReloadAnalyzers (
570574 String synonymSetId ,
571575 boolean refresh ,
572576 boolean preview ,
@@ -596,16 +600,20 @@ private <T> void maybeReloadAnalyzers(
596600 return ;
597601 }
598602
599- // auto-reload all reloadable analyzers (currently only those that use updateable synonym or keyword_marker filters)
600- ReloadAnalyzersRequest reloadAnalyzersRequest = new ReloadAnalyzersRequest (synonymSetId , preview , "*" );
601- client .execute (
602- TransportReloadAnalyzersAction .TYPE ,
603- reloadAnalyzersRequest ,
604- listener .safeMap (reloadResponse -> new SynonymsReloadResult (synonymsOperationResult , reloadResponse ))
605- );
603+ reloadAnalyzers (synonymSetId , preview , synonymsOperationResult , listener );
606604 }));
607605 }
608606
607+ private void reloadAnalyzers (String synonymSetId , boolean preview , UpdateSynonymsResultStatus synonymsOperationResult , ActionListener <SynonymsReloadResult > listener ) {
608+ // auto-reload all reloadable analyzers (currently only those that use updateable synonym or keyword_marker filters)
609+ ReloadAnalyzersRequest reloadAnalyzersRequest = new ReloadAnalyzersRequest (synonymSetId , preview , "*" );
610+ client .execute (
611+ TransportReloadAnalyzersAction .TYPE ,
612+ reloadAnalyzersRequest ,
613+ listener .safeMap (reloadResponse -> new SynonymsReloadResult (synonymsOperationResult , reloadResponse ))
614+ );
615+ }
616+
609617 // Allows checking failures in tests
610618 void checkSynonymsIndexHealth (ActionListener <ClusterHealthResponse > listener ) {
611619 ClusterHealthRequest healthRequest = new ClusterHealthRequest (
0 commit comments