|
@@ -122,7 +122,7 @@ class AclTaskMixin:
|
122
|
122
|
async def ws_conn0(self):
|
123
|
123
|
if glob_cl.has_cl:
|
124
|
124
|
return
|
125
|
|
- glob_cl = True
|
|
125
|
+ glob_cl.has_cl = True
|
126
|
126
|
print("AclTaskMixin:ws_conn0")
|
127
|
127
|
glob_cl.run_persistent_loop(self)
|
128
|
128
|
glob_cl.acl = self.channel_layer
|
|
@@ -249,7 +249,6 @@ class globCL(GCLMixin):
|
249
|
249
|
channel_layer = glob_cl.acl
|
250
|
250
|
if not consumer.channel_name in consumer.groups_set:
|
251
|
251
|
consumer.groups_set.add(groups)
|
252
|
|
- consumer.groups
|
253
|
252
|
await channel_layer.group_add(group_name,consumer.channel_name)
|
254
|
253
|
|
255
|
254
|
|