You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I just want to know if there is a specific time to publish the message after reading it when using aiopika, because when i tried a process that takes a few time, I get "channel is closed" when publishing the message, here is a part of a test code I used:
async def on_message(self, exchange: Exchange, message: IncomingMessage):
with message.process():
time.sleep(200) # this is to replace the process, so i can get "channel is closed"
await exchange.publish(
Message(
body=output_msg.SerializeToString(),
correlation_id=message.correlation_id,
),
routing_key=message.reply_to,
)
For what reason the publish doesn't work and i receive channel is close?
I'm using aio-pika 6.8.1
Thank you in advance.
Regards
The text was updated successfully, but these errors were encountered:
Hello lads,
I just want to know if there is a specific time to publish the message after reading it when using aiopika, because when i tried a process that takes a few time, I get "channel is closed" when publishing the message, here is a part of a test code I used:
For what reason the publish doesn't work and i receive channel is close?
I'm using aio-pika 6.8.1
Thank you in advance.
Regards
The text was updated successfully, but these errors were encountered: