I know that we can do this to list queue in a rabbitmq: rabbitmqctl list_queues but how can I do this via pika?

I'm using pika in a kubernetes cluster and consuming messages from a queue, which triggers initiating a function in a new thread. However RabbitMQ seems crash, these are the best logs I've found so...

I am finding it impossible to set up an encrypted connection with a RabbitMQ broker using python's pika library on the client side. My starting point was the pika tutorial example here but I cannot...

I am using Python which is using RabbitMQ for input and output. I am able to run my script locally without any errors but when I try to Dockerize that script and run it it's giving me the following...

Going through the Rabbit MQ Pika HelloWorld tutorial found here: https://www.rabbitmq.com/tutorials/tutorial-one-python.html The problem is, I keep getting this error whenever I run my receive scri...

I use pika basic_get method to get message from rabbitmq and basic_ack method to do ack. import pika connection = pika.BlockingConnection( pika.ConnectionParameters( host="rabbitmq", ...

I have the following code where I initialize a consumer listening to a queue. consumer = MyConsumer() consumer.declare_queue(queue_name="my-jobs") consumer.declare_exchange(exchange_name=...

I am using an external service (Service) to process some particular type of objects. The Service works faster if I send objects in batches of 10. My current architecture is as follows. A producer b...

In my unit test, I want to simply start consuming, publish a message, and receive a response back and assert if the response is what I expect it to be. However, I have been trying to do this for ho...

I need some help. I have this code below and the logs tell me that I'm not passing the durable parameter, but as you can see I'm passing. I have tried everything and there is always the same mistak...

I have hard times to demonstrate that the consumer_timeout setting is working as expected. I may have done things wrong or misunderstood the consumer_timeout behavior. All my code for testing is av...

I am trying to convert my code to send rabbitmq messages via Pika instead. I am having a lot of trouble understanding how to send a simple message using an asynchronous connection (such as SelectCo...

I'm new to rabbitmq and pika, and is having trouble with stopping consuming. channel and queue setting: connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = conn...

i have an issue that happens only on my publisher side of pika. the architecture of the project: - Kubernetes cluster: - Flask Server Pod: - publisher running - Consumer Pod: - Consumer Running...

I have a task queue in RabbitMQ with multiple producers (12) and one consumer for heavy tasks in a webapp. When I run the consumer it starts dequeuing some of the messages before crashing with this...

I'm trying to constantly listen for the queue, but after about a minute (assuming my queue is empty ) I got disconnected with this error: DEBUG:pika.adapters.blocking_connection:Outbound buffer si...

How do you ensure that messages get delivered with Pika? By default it will not provide you with an error if the message was not delivered succesfully. In this example several messages can be sent...

I have two, separate RabbitMQ instances. I'm trying to find the best way to listen to events from both. For example, I can consume events on one with the following: credentials = pika.PlainCreden...

We're trying to set up a basic directed queue system where a producer will generate several tasks and one or more consumers will grab a task at a time, process it, and acknowledge the message. The...

I installed pika for python running on a mac sudo pip install pika==0.9.8 I make sure is installed, this is the response when trying to reinstall, Requirement already satisfied (use --upgrade t...

The example here shows how to create both client & server in python using Remote procedure call (RPC). But I can't imagine how the FastAPI service might be a server to consume requests from RCP...

I am using rabbitmq to facilitate some tasks from my rabbit server to my respective consumers. I have noticed that when I run some rather lengthy tests, 20+ minutes, my consumer will lose contact w...

searched through stackoverflow and posting this question because no solution worked for me and my question might be different from other question. I am writing a script which gets an article from ...

I am trying to create a consumer that would subscribe to multiple queues, and then process messages as they arrive. The problem is that when there is some data already present in the first queue,...

I tried to send message and receive message using RabbitMQ. I dont have computer science background, the terms I used could not be very accurate. I try to copy the tutorial file: When submitting my...