I have installed celery and RabitMQ and flower. I am able to browse to the flower port. I have the following simple worker that I can attach to celery and call from a python program: # -*- coding:...

Simple question, but Google or the Pika open source code did not help. Is there a way to query the current queue size (item counter) in Pika?

I need to have a python client that can discover queues on a restarted RabbitMQ server exchange, and then start up a clients to resume consuming messages from each queue. How can I discover queues ...

I am able to create a fanout exchange using the Publish/Subscribe RabbitMQ Java tutorial, and any connected consumer will receive a copy of a message. Instead of declaring an exchange and binding d...

i want to install AMQP in windows 10 with PHP 7.3 for use in symfony 4. windows not use any apache/iis/nginx and run directly by symfony. everything ok! until, i decide to use rabbitmq in project...

To my knowledge, Celery acts as both the producer and consumer of messages. This is not what I want to achieve. I want Celery to act as the consumer only, to fire certain tasks based on messages th...

I understand below prefetch simply controls how many messsages the broker allows to be outstanding at the consumer at a time. When set to 1, this means the broker will send 1 message, wait for the ...

I need some help. I'm developing a spring boot application, and I want wo publish messages to a rabbitMQ. I want to send it to a queue, that is named in the message itself. This way i want to crea...

I have a RabbitMQ consumer script in Go. This is a simple script from RabbitMQ tutorial that uses streadway/amqp library. The problem is that if the RabbitMQ server is stopped, the consumer script ...

One of my projects requires authentication for using RabbitMQ. Only authenticated users can connect to the rabbitmq server and subscribe to queues etc. For example, when a user connects to the serv...

I try to send an object via AMQP messaging (RabbitMQ) but when I receive the message the converter raise a JsonMappingException because it was unable to deserialize that message. Order.java: impo...

As I follow the celery documentation > from celeryapp import app > i = app.control.inspect() > i.active() The inspection seems to hang. Has anyone seen this before? And can anyone shed ...

I am trying to understand what JMS and how it is connected to AMQP terminology. I know JMS is an API and AMQP is a protocol. Here are my assumptions (and questions as well) RabbitMQ uses AMQP p...

In my (limited) experience with rabbit-mq, if you create a new listener for a queue that doesn't exist yet, the queue is automatically created. I'm trying to use the Spring AMQP project with rabbit...

In the REST world, we have something like a Swagger Specification, which fully describes the contract over a REST interface boundary (between client and server). Those Swagger specifications ...

I am having this error while installing pecl/amqp when I type in the command line: pear install pecl/amqp WARNING: php_bin C:\xampp\php.\php.exe appears to have a suffix .\php.exe, but co...

I'm using Celery with an AMQP broker to call tasks, but the response needs to be passed back with a different queue architecture than Celery uses, so I want to pass the messages back using Kombu on...

I am writing amqp 1.0 client (using rabbitMQ.Client in .NET) for a broker who provided me the following information: amqps://brokerRemoteHostName:5671 certificate_openssl.p12 password for certifi...

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...

I have found Example for Sending String in rabittMq and Receiving from the queue but I am not clear about about these methods - assertQueue , sendToQueue send.js var amqp = require('amqplib/call...

I'm using amqplib which I'm trying to implement a reconnecting mechanism. However, after the connection is reestablished it looks like my channel is still closed. How do I fix this issue? This is m...

I am very new to RabbitMQ. I have set up a 'topic' exchange. The consumers may be started after the publisher. I'd like the consumers to be able to receive messages that have been sent before they ...

So I am using rabbitmqs http api to do some very basic actions in rabbit. It works great in most situations but I am having an issue figuring out how to use it to publish a message to the default r...

I need some help cause I don't have any idea what to do. I have to use 'amqplib' in my Angular project. Firstly I have tried to use 'amqp-ts', but as soon as I've opened a browser I had an error: A...

I´m sending a message to a topic exchange which hasn´t any bindings to any queues. Just a blank exchange. The channel is created as confirm channel and my confirm callback is called each time I sen...