@@ -149,6 +149,7 @@ def initMsgFunc(request):
if not is_distributed:
thread_kwargs = {
'user_id': userID,
+ 'redis_obj': redis_obj,
'distribute_key': distribute_key,
'expire': expire,
'end_time': end_time
