|
@@ -86,7 +86,7 @@ class RabbitAsyncCommunicator(threading.Thread):
|
|
|
await message.ack()
|
|
|
if self._closing==True:
|
|
|
return
|
|
|
- async def recv_statu(self,ex_name,key,ttl=1000):
|
|
|
+ async def recv_statu(self,ex_name,key,ttl=200):
|
|
|
statu_ex=await self._channel_statu.get_exchange(ex_name)
|
|
|
arg={}
|
|
|
arg["x-message-ttl"]=ttl
|