using latest lettuce core

Author: jruaux

pom.xml

@@ -1,5 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 	<modelVersion>4.0.0</modelVersion>
 
 	<parent>
@@ -28,6 +30,14 @@
 			<id>java.net</id>
 			<url>https://oss.sonatype.org/content/repositories/snapshots</url>
 		</repository>
+		<repository>
+			<id>sonatype-snapshots</id>
+			<name>Sonatype Snapshot Repository</name>
+			<url>https://oss.sonatype.org/content/repositories/snapshots/</url>
+			<snapshots>
+				<enabled>true</enabled>
+			</snapshots>
+		</repository>
 	</repositories>
 
 	<dependencies>
@@ -40,10 +50,15 @@
 			<artifactId>lombok</artifactId>
 			<optional>true</optional>
 		</dependency>
+		<dependency>
+			<groupId>io.lettuce</groupId>
+			<artifactId>lettuce-core</artifactId>
+			<version>5.2.0.BUILD-SNAPSHOT</version>
+		</dependency>		
 		<dependency>
 			<groupId>com.redislabs</groupId>
 			<artifactId>lettusearch</artifactId>
-			<version>1.0.0</version>
+			<version>1.0.3-SNAPSHOT</version>
 		</dependency>
 		<dependency>
 			<groupId>org.springframework.boot</groupId>

src/main/java/com/redislabs/springredisearch/RediSearchConfiguration.java

@@ -11,6 +11,7 @@
 import com.redislabs.lettusearch.RediSearchClient;
 import com.redislabs.lettusearch.StatefulRediSearchConnection;
 
+import io.lettuce.core.ClientOptions;
 import io.lettuce.core.RedisURI;
 import io.lettuce.core.resource.ClientResources;
 import io.lettuce.core.resource.DefaultClientResources;
@@ -32,6 +33,7 @@ public class RediSearchConfiguration {
 	private Integer port;
 	private String password;
 	private Duration timeout;
+	private boolean publishOnScheduler;
 
 	@Bean(destroyMethod = "shutdown")
 	ClientResources clientResources() {
@@ -49,7 +51,9 @@ RediSearchClient client(ClientResources clientResources) {
 		if (timeout != null) {
 			redisURI.setTimeout(timeout);
 		}
-		return RediSearchClient.create(clientResources, redisURI);
+		RediSearchClient client = RediSearchClient.create(clientResources, redisURI);
+		client.setOptions(ClientOptions.builder().publishOnScheduler(publishOnScheduler).build());
+		return client;
 	}
 
 	@Bean(destroyMethod = "close")