indexUpdateCallback.store(paramMap, dataMap);

        // Verify indexing was triggered
        assertEquals(1, indexingHelper.sendDocumentsCalled);
    }

    @Test
    public void test_commit() {
        // Add documents to cache
        DataStoreParams paramMap = new DataStoreParams();
        Map<String, Object> dataMap1 = new HashMap<>();
        dataMap1.put("url", "http://example.com/test1");