Hi. I am trying to use RedisPubSub and noticed that Message case cla

Sub Message data type about rediscala HOT 2 CLOSED

btd commented on July 18, 2024

Sub Message data type

from rediscala.

Comments (2)

etaty commented on July 18, 2024

Yes you are right.
If you want to do a PR, you have to remove the last utf8String calls for Message and PMessage

rediscala/src/main/scala/redis/actors/RedisSubscriberActor.scala

Lines 93 to 96 in 1096f43

 onMessage(Message(list(1).toByteString.utf8String, list(2).toByteString.utf8String)) 

 } 

 case MultiBulk(Some(list)) if list.length == 4 && list.head.toByteString.utf8String == "pmessage" => { 

 onPMessage(PMessage(list(1).toByteString.utf8String, list(2).toByteString.utf8String, list(3).toByteString.utf8String))

from rediscala.

etaty commented on July 18, 2024

fix merged for version 1.5
Thanks

from rediscala.

Related Issues (20)

can update akka 2.5.10+? HOT 2
stop() not part of a trait
Question: How to distinguish between operation failures
Timeouts for RedisClientPool
rediscala endless retry loop when connection fails
Redis streams support? HOT 1
This is a mistaken issue..deleted.
UnsupportedClassVersionError HOT 8
Redis Protocol error: Got 43 as initial reply byte
Please make a patch release, with fixes for RedisCluster
Smembers is set as isMasterOnly = true HOT 1
[Question] why sentinel not support sentinel auth?
[Question] Should RedisClientPool extend Transactions?
[Question] Use SSL to Authenticate
creating a RedisClient from a typed akka behavior
[Question] Akka Dispatch error when using rediscala.
How we can do health check for redis cluster using `redisscala`?
Null pointer exception at redis.RedisCluster.$anonfun$onConnectStatus$1
A new connection is getting created every time
Support for pekko HOT 1

Sub Message data type about rediscala HOT 2 CLOSED

Comments (2)

Related Issues (20)

Recommend Projects

React

Vue.js

Typescript

TensorFlow

Django

Laravel

D3

Recommend Topics

javascript

web

server

Machine learning

Visualization

Game

Recommend Org

Facebook

Microsoft

Google

Alibaba

D3

Tencent

	onMessage(Message(list(1).toByteString.utf8String, list(2).toByteString.utf8String))
	}
	case MultiBulk(Some(list)) if list.length == 4 && list.head.toByteString.utf8String == "pmessage" => {
	onPMessage(PMessage(list(1).toByteString.utf8String, list(2).toByteString.utf8String, list(3).toByteString.utf8String))