More decRef() in tests

querqy · Aug 28, 2024 · 9eea8f7 · 9eea8f7
1 parent 35e05b9
commit 9eea8f7
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/src/test/java/querqy/elasticsearch/rewriter/SimpleCommonRulesRewriterFactoryTest.java b/src/test/java/querqy/elasticsearch/rewriter/SimpleCommonRulesRewriterFactoryTest.java
@@ -35,7 +35,7 @@ public void testBooleanInput() throws ExecutionException, InterruptedException {
 
         final PutRewriterRequest request = new PutRewriterRequest("common_rules", content);
 
-        client().execute(PutRewriterAction.INSTANCE, request).get();
+        client().execute(PutRewriterAction.INSTANCE, request).get().decRef();
 
         QuerqyQueryBuilder querqyQuery = new QuerqyQueryBuilder(getInstanceFromNode(QuerqyProcessor.class));
         querqyQuery.setRewriters(singletonList(new Rewriter("common_rules")));
@@ -52,6 +52,8 @@ public void testBooleanInput() throws ExecutionException, InterruptedException {
         assertEquals(2L, hits.getTotalHits().value);
         assertEquals("2", hits.getHits()[0].getSourceAsMap().get("id"));
 
+        response.decRef();
+
         querqyQuery = new QuerqyQueryBuilder(getInstanceFromNode(QuerqyProcessor.class));
         querqyQuery.setRewriters(singletonList(new Rewriter("common_rules")));
         querqyQuery.setMatchingQuery(new MatchingQuery("a b"));
@@ -67,6 +69,8 @@ public void testBooleanInput() throws ExecutionException, InterruptedException {
         assertEquals(2L, hits.getTotalHits().value);
         assertEquals("1", hits.getHits()[0].getSourceAsMap().get("id"));
 
+        response.decRef();
+
     }
 
     public void testRuleSelectionCriteria() throws ExecutionException, InterruptedException {
@@ -85,7 +89,7 @@ public void testRuleSelectionCriteria() throws ExecutionException, InterruptedEx
 
         final PutRewriterRequest request = new PutRewriterRequest("common_rules", content);
 
-        client().execute(PutRewriterAction.INSTANCE, request).get();
+        client().execute(PutRewriterAction.INSTANCE, request).get().decRef();
 
         QuerqyQueryBuilder querqyQuery = new QuerqyQueryBuilder(getInstanceFromNode(QuerqyProcessor.class));
 
@@ -110,6 +114,8 @@ public void testRuleSelectionCriteria() throws ExecutionException, InterruptedEx
 
         assertEquals(2L, hits.getTotalHits().value);
 
+        response.decRef();
+
 
         querqyQuery = new QuerqyQueryBuilder(getInstanceFromNode(QuerqyProcessor.class));
         criteria.put("filter", "$[?(@.lang == 'l2')]");
@@ -127,7 +133,7 @@ public void testRuleSelectionCriteria() throws ExecutionException, InterruptedEx
 
         assertEquals(1L, hits.getTotalHits().value);
 
-
+        response.decRef();
 
     }