un-hide async()

redis · Oct 9, 2023 · c77db6c · c77db6c
1 parent 249e0eb
commit c77db6c
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/redis-om-spring/src/main/java/com/redis/om/spring/RediSearchIndexer.java b/redis-om-spring/src/main/java/com/redis/om/spring/RediSearchIndexer.java
@@ -772,7 +772,10 @@ private FTCreateParams createIndexDefinition(Class<?> cl, IndexDataType idxType)
 
     if (cl.isAnnotationPresent(Document.class)) {
       Document document = cl.getAnnotation(Document.class);
-      //params.setAsync(document.async());
+      // params.setAsync(document.async()); // TODO:
+      if (document.async()) {
+        throw new UnsupportedOperationException("ASYNC is not supported.");
+      }
       Optional.ofNullable(document.filter()).filter(ObjectUtils::isNotEmpty).ifPresent(params::filter);
       Optional.ofNullable(document.language()).filter(ObjectUtils::isNotEmpty).ifPresent(lang -> params.language(lang.getValue()));
       Optional.ofNullable(document.languageField()).filter(ObjectUtils::isNotEmpty).ifPresent(params::languageField);

diff --git a/redis-om-spring/src/main/java/com/redis/om/spring/annotations/Document.java b/redis-om-spring/src/main/java/com/redis/om/spring/annotations/Document.java
@@ -17,7 +17,7 @@
   @AliasFor(annotation = KeySpace.class, attribute = "value")
   String value() default "";
 
-  //boolean async() default false;
+  boolean async() default false; // TODO:
   String[] prefixes() default {};
   String filter() default "";
   String languageField() default "";