回调状态修改
This commit is contained in:
parent
4e9a03eb21
commit
b053a13865
|
@ -23,8 +23,6 @@ class JQRMSGPubSubUtils:
|
|||
|
||||
|
||||
def listen():
|
||||
api = os.environ.get('api')
|
||||
logger.info(f'监听消息队列-----{api}')
|
||||
from apps.jqr.serializers import TbMessageModelSerializer
|
||||
while True:
|
||||
data = JQRMSGPubSubUtils.rc.brpop(Constant.JQR_MSG_PUBSUB_CHANNEL, 5)
|
||||
|
|
Loading…
Reference in New Issue