Enforced cast to string for any object posted to the Redis bus

This commit is contained in:
Fabio Manganiello 2018-11-20 14:18:58 +00:00
parent 68dcdf8ccd
commit c2be1cf6e8

View file

@ -39,7 +39,7 @@ class RedisPlugin(Plugin):
"""
redis = Redis(*args, **kwargs)
redis.rpush(queue, msg)
redis.rpush(queue, str(msg))
@action
def mget(self, keys, *args):