Top "Rabbitmq" questions

How to route a chain of tasks to a specific queue in celery?

When I route a task to a particular queue it works: task.apply_async(queue='beetroot') But if I create …

python rabbitmq celery chain

Celery & RabbitMQ running as docker containers: Received unregistered task of type '...'

I am relatively new to docker, celery and rabbitMQ. In our project we currently have the following setup: 1 physical host …

python docker rabbitmq celery amqp

How to copy messages to another queue on RabbitMQ?

Using RabbitMQ as broker, I would like to copy all the messages from one queue to another queue for test/…

rabbitmq message-queue amqp rabbitmqctl

EasyNetQ fails to publish to RabbitMQ - PersistentChannel timed out

I am trying to connect to RabbitMQ with EasyNetQ. RabbitMQ is on remote VM. _rabbitBus = RabbitHutch.CreateBus( string.Format("host={0};…

rabbitmq cqrs easynetq

Python Pika - Consumer into Thread

I'm working on a Python app with a background thread for consuming message from a RabbitMQ Queue (topic scenario). I …

python multithreading rabbitmq pika

Client unexpectedly closed TCP connection

I have a couple of tasks running as a service. To kick off the worker I use: def SvcDoRun(self): …

python rabbitmq celery rabbitmq-exchange

celeryev Queue in RabbitMQ Becomes Very Large

I am using celery on rabbitmq. I have been sending thousands of messages to the queue and they are being …

rabbitmq celery django-celery

AMQP: acknowledgement and prefetching

I try to understand some aspects of AMQP protocol. Currently I have project with RabbitMQ and use python pika library. …

python rabbitmq amqp pika

Prevent @RabbitListener in spring-rabbit from trying to connect to server during integration test

I want to run some acceptance tests for my services that are using rabbitMq but I want to ignore all …

java spring rabbitmq spring-rabbit

RabbitMQ suspend queue consumption

What is the best way to keep a durable queue and its bindings but suspend its consumers? The use case …

java rabbitmq amqp spring-amqp