RedisStore _publishers needs to be an instance variable (not class) about django-websocket-redis HOT 6 CLOSED

using which API?

BTW, which version

from django-websocket-redis.

Did you implement it as written here?
http://django-websocket-redis.readthedocs.org/en/latest/api.html

from django-websocket-redis.

i'm using current git and i need to publish messages to different facilities from a celery task so i do:
b = RedisPublisher(facility='team-0", broadcast=True)
b.publish_message("test0")
b = RedisPublisher(facility='team-1", broadcast=True)
b.publish_message("test1")
The first message will go to "team-0" but the second message will go to both team-0 and team-1.

from django-websocket-redis.

(current git as yesterday.. i didn't have time to check again today)

from django-websocket-redis.

If you want to dispatch a message to different users, instead of using a different facility, you should use a different audience, say:

b = RedisPublisher(facility='a_name', user='team-0')
b.publish_message("test0")
b = RedisPublisher(facility='a_name', user='team-1')
b.publish_message("test1")

but anyway, your code is correct and indeed this seems weird.
Could you please check with redis-cli what kind of messages have been added.
For this WS4REDIS_EXPIRE must be, say 3600.

# redis-cli
redis 127.0.0.1:6379> get broadcast:team-0
redis 127.0.0.1:6379> get broadcast:team-1

from django-websocket-redis.

As i said(maybe i've not explained it very well, sorry for that!) in the first report the problem is that the class RedisStore declares _publishers as a class variable. This means that all RedisStore instances will share the same _publishers variable. For example this code:

class TestC:
    _a = []
    def __init__(self):
        self._b = []

    def test(self):
        self._a.append('a')
        self._b.append('b')
        return (self._a, self._b)

b = TestC()
print b.test()
c = TestC()
print c.test()

will output

(['a'], ['b'])
(['a', 'a'], ['b'])

You don't want _publishers to be a class variable but an instance variable and so you have to declare it inside init. I hope i made myself clear!

from django-websocket-redis.