fix(2971): spublish typo fix (#2972) (#2975)

fixing #2971 Co-authored-by: Jedrzej Krauze <jedrzej.krauze@gmail.com>
redis · Aug 26, 2024 · 385275b · 385275b
1 parent 83f459a
commit 385275b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/io/lettuce/core/pubsub/RedisPubSubReactiveCommandsImpl.java b/src/main/java/io/lettuce/core/pubsub/RedisPubSubReactiveCommandsImpl.java
@@ -161,7 +161,7 @@ public Mono<Map<K, Long>> pubsubShardNumsub(K... shardChannels) {
 
     @Override
     public Mono<Long> spublish(K shardChannel, V message) {
-        return createMono(() -> commandBuilder.publish(shardChannel, message));
+        return createMono(() -> commandBuilder.spublish(shardChannel, message));
     }
 
     @Override