subscribe fails with ConnectionError

[milyenpabo]

Subscribe consistently fails with ConnectionError. Example code snippet:

rc = RedisCluster(startup_nodes=[{'host': '10.0.0.1', 'port': '7001'}])
pubsub = rc.pubsub()
pubsub.subscribe(**{'mychannel': mycallback})

def mycallbak(msg):
    pass

The problem is that rc.pubsub() returns a PubSub object (from StrictRedis), which is not aware of the cluster node addresses. Thus on rc.subscribe() it tries to connect to a default Redis endpoint on localhost:6379, which fails with the following error:

redis.exceptions.ConnectionError: Error 111 connecting to localhost:6379. Connection refused.

[Grokzen]

Thanks for the report. I will look into this during the weekend.

[Grokzen]

@milyenpabo Added fix in the mentioned commit. Will merge it into master branch during the day so this issue will be closed.

I tested with a modified script

from rediscluster import RedisCluster


def mycallback(msg):
    print("My callback...")
    print(msg)


rc = RedisCluster(startup_nodes=[{'host': '127.0.0.1', 'port': 7001}])

pubsub = rc.pubsub()
a = pubsub.subscribe(**{'mychannel': mycallback})

for b in pubsub.listen():
    print(b)

[Grokzen]

@milyenpabo If you have any other problems with pubsub please open more Issues with some test code and I will look into them.

[milyenpabo]

Thanks for the quick fix, it works.