Use regular subscribe for client specific callback channel

Warriorrrr · Warriorrrr · commit dc8c1a51f8f5 · 2026-01-18T23:51:47.000+01:00
diff --git a/client/src/main/java/net/earthmc/mycelium/client/impl/messaging/callback/CallbackProvider.java b/client/src/main/java/net/earthmc/mycelium/client/impl/messaging/callback/CallbackProvider.java
@@ -73,7 +73,7 @@ public void onMessage(String channel, String message) {
             }
         };
 
-        this.pollThread.submit(() -> this.client.redis().psubscribe(this.listener, this.channel));
+        this.pollThread.submit(() -> this.client.redis().subscribe(this.listener, this.channel));
     }
 
     public <T> void await(String messageUUID, JsonCodec<T> codec, CallbackOptions options, Consumer<IncomingMessage<T>> callback) {

Original file line number	Diff line number	Diff line change
`@@ -73,7 +73,7 @@ public void onMessage(String channel, String message) {`
`73`	`73`	`}`
`74`	`74`	`};`
`75`	`75`
`76`		`- this.pollThread.submit(() -> this.client.redis().psubscribe(this.listener, this.channel));`
	`76`	`+ this.pollThread.submit(() -> this.client.redis().subscribe(this.listener, this.channel));`
`77`	`77`	`}`
`78`	`78`
`79`	`79`	`public <T> void await(String messageUUID, JsonCodec<T> codec, CallbackOptions options, Consumer<IncomingMessage<T>> callback) {`