Replies: 2 comments 1 reply
-
Hello, thanks for using Pika and RabbitMQ. There is very little I can suggest based on a couple code snippets. I have no idea how you are using Python threads, for instance. If you can provide code that I can run to reproduce the issue, I could probably assist you. Otherwise, I don't have the time to investigate. Note that you are using unsupported versions of all of your software. |
Beta Was this translation helpful? Give feedback.
0 replies
-
I found the cause of my issue, it wasn't related to pika or RabbitMQ. |
Beta Was this translation helpful? Give feedback.
1 reply
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
I'm encountering a problem in our production environment that I can't replicate locally.
After processing over 2.5 million messages from our RabbitMQ queue over approximately 5 hours, the processing thread stops unexpectedly. The thread runs a straightforward function, but it seems to hang at the following segment of code:
The
parameters
only specify the host, port, and credentials.Unfortunately, I'm uncertain which specific line is causing the issue.
Previously, we encountered a similar problem when new connections were added to our application without being properly closed, leading to resource exhaustion (what we believe), specifically socket-related resources. Closing those connections resolved the issue at that time. However, the problem has resurfaced after integrating a security agent that also utilizes socket connections. Although this agent appears to manage socket connections properly, the concurrent use of multiple connections might be contributing to the issue.
I would like to modify the setup so that it throws an exception instead of just hanging when a problem occurs. How can we address this issue?
I have two other threads that are connected to RabbitMQ and they operate without any issues, even when the thread that is causing problems experiences a hang-up.
The first one code snippet:
The second one:
package versions:
RabbitMQ 3.8.11
Erlang 22.3
pika 1.2.0
python 3.6.13
Beta Was this translation helpful? Give feedback.
All reactions