Questions tagged [rabbitmq]

RabbitMQ is an open-source message broker originally implementing the AMQP protocol with additional messaging protocols supported via a plug-in architecture. This tag should be used with questions involving the RabbitMQ server message broker product or questions concerning the source code and implementation of the RabbitMQ product. A specific protocol tag such as amqp or mqtt may also be appropriate as well as the OS and programming language being used.

Filter by
Sorted by
Tagged with
0 votes
0 answers
5 views

Understanding async functions calls in Rust with RabbitMQ

I'm new in Rust and I am struggling a little bit with async functions. The goal of my program is to send messages to a RabbitMQ queue. I have defined two functions, one to get the channel and another ...
JuanN's user avatar
  • 696
0 votes
0 answers
5 views

aio-pika RabbitMQ cluster

I am using aio-pika 6.8.0 to connect to a RabbitMQ cluster. However, I can only provide one host using below method. from aio_pika import connect connection = await connect(rabbitmq_url) Now, I want ...
dab92's user avatar
  • 155
0 votes
0 answers
5 views

Unable to generate logs for the installation of Erlang and RabbitMQ installer in Windows

I am using Erlang version 25.2.3 and RabbitMQ version 3.11.10. I am using .exe installer to install it in windows machine silently. I want to generate logs for the installation by using both ...
asif0012's user avatar
0 votes
0 answers
6 views

Cannot connect to RabbitMQ using a C# service - None of the specified endpoints were reachable

I have created a C# Windows service using the Windows sevice (.NET Framework) template to connect to RabbitMQ to run on Windows 10, but I get an Exception "None of the specified endpoints were ...
ChrisR's user avatar
  • 1
0 votes
0 answers
8 views

De duplication in AlertManager for dynamic label values

I have a prometheus rule to get alerts when messages in rabbitmq have crossed the threshold. I have exposed metrics for RabbitMQ /metrics/per-object to get the queue name as well. When the alert gets ...
Mahnoor Fatima's user avatar
0 votes
0 answers
10 views

How do I resolve the 'Stream connection lost' error when using RabbitMQ in Python?

hi guys i have problem with connection.channel() in python for rabbit-mq . when i run my code in send and receive connection close forcibly , this is the error pika.exceptions.StreamLostError: Stream ...
hamed's user avatar
  • 1
0 votes
0 answers
8 views

Unable to connect SpringBoot to AWS RabbitMQ: Error - ACCESS_REFUSED - Login was refused using authentication mechanism PLAIN

When I use SpringBoot to connect to AWS RabbitMQ, an error is reported:ACCESS_REFUSED - Login was refused using authentication mechanism PLAIN. For details see the broker logfile. <parent> ...
xukainan's user avatar
0 votes
1 answer
4 views

RabbitMQ + MQTT: unable to publish any messages: login timeout

I deployed a RabbitMQ server with an MQTT plugin. All of a sudden, my app was no able to publish any messages: info: paho: MQTT Client using: ssl://example.com:8883/ error: paho: [net] connect ...
kolypto's user avatar
  • 30.9k
0 votes
0 answers
16 views

inequivalent arg 'x-queue-type' for queue 'email.queue' in vhost 'Email': received none but current is the value 'quorum' of type 'longstr'

I have WSO2 project which has RabbitMQ message store configured as follows: <messageStore class="org.apache.synapse.message.store.impl.rabbitmq.RabbitMQStore" name="...
Mahmoud Saleh's user avatar
0 votes
1 answer
30 views

How safe is setting consumer_timeout to long values like 10years

Im guessing it's there for a reason, but I can't seem to find any answer to this question. In short I have a django app where users get set badges that months or even years down the line need to be ...
Ianis Donica's user avatar
0 votes
0 answers
7 views

Why am I unable to see my Celery task queue in RabbitMQ's management interface?

I'm facing an issue where I'm unable to see the information about my queue in the RabbitMQ broker, but I can see the information in my Celery task console. I'm using Celery as a distributed task queue ...
rriol's user avatar
  • 1
0 votes
1 answer
17 views

rabbitmq-node ECONNRESET on channel creation after successful connection has been established

I fresh installed rabbitmq and amqp-lib and imported var amqp = require('amqplib/callback_api'); amqp.connect('admin://admin:guest@localhost:5672',function(error0, connection) { console.log(&...
kostas kostidis's user avatar
0 votes
0 answers
21 views

RabbitMQ consumer in cluster (message lost)

Given the following scenario : RabbitListener (I'm using spring rabbit but probably this is not relevant) receive a message M1 in quorum queue (I dont know if M1 has been sent with publish confirms ...
obe6's user avatar
  • 1,741
0 votes
0 answers
14 views

Queues in RabbitMQ Management are not displayed

I am stuck with the following problem: I am trying to use .Net 6/C# with RabbitMQ by using RabbitMQ.Client library. I use docker to get the container of RabbitMQ. The following command is applied: ...
TeaLocust's user avatar
0 votes
0 answers
4 views

RabbitMQ rotate Single Active Consumer

The RabbitMQ documentation is not clear about this (because it's probably not possible), hence my question here: I have a large number of queues, all with Single Active Consumer enabled. Now, I have ...
Keugels's user avatar
  • 750
0 votes
0 answers
7 views

KeyError: 'payment_publisher.publish_payment_data' when using Celery

I'm encountering an error while working with Celery 5.2.7 in my Python project. The error message and traceback are as follows: The delivery info for this task is: {'consumer_tag': 'None4', '...
gbeto Jean-José's user avatar
0 votes
0 answers
11 views

RabbitMQ creating idle queues having no consumers

Problems High Memory Usage Blocked Workers High Number of channels and Connections Blocked Connections Deployment Aws EKS I have a Django application and have long-running tasks implemented in celery ...
chirag's user avatar
  • 153
0 votes
1 answer
30 views

TypeError: this.metadataScanner.getAllMethodNames is not a function in NestJS version 9

I am using NestJS version 9 and trying to connect my apps through rabbitmq. However, I am getting the following error: TypeError: this.metadataScanner.getAllMethodNames is not a function from this ...
Mahdi Toosi's user avatar
0 votes
0 answers
24 views

Getting "c.r.c.impl.ForgivingExceptionHandler: An unexpected connection driver error occurred (Exception message: Connection reset)" in java rabbitmq

Getting "c.r.c.impl.ForgivingExceptionHandler: An unexpected connection driver error occurred (Exception message: Connection reset)" when running java project with rabbitmq Java version - 11 ...
Yashika Rajput's user avatar
0 votes
0 answers
19 views

Sharing Pika Connection Singleton Object between gunicron workers on django application

Hi I am trying to connect to email queue from django application. I have created an EmailPublisher which will be a singleton object which extends RabbitMQProducer object which has actual code of ...
Ayush Srivastava's user avatar
0 votes
0 answers
20 views

How can I follow messages instantly when using RabbitMQ in PHP? [closed]

I am using RabbitMQ with PHP. When I add something to the queue with a web browser, is there a way to instantly show if it's complete? I'm sending a bounce message to the client but after the web page ...
Enes Akarsu's user avatar
0 votes
0 answers
13 views

Sending messages > ~3.5MB for AMQP CPP blocks for >30s

When publishing messages which are larger than ~3.5MB (amqp.publish()), they only appear in the RabbitMQ library after a "big" delay. (>30s). If the package is smaller, the message ...
Patrick Schmelzer's user avatar
0 votes
0 answers
15 views

Error in implementing Microservices with Express.ts and Rabbit MQ

Rabbit mq file import express from "express"; import amqplib, { Message } from "amqplib"; const app = express(); const port = 3000; app.get("/", (req, res) => { res.send("Hello world ...
Rishikesh singh's user avatar
0 votes
0 answers
17 views

How to get the data consumed by the consumer in RabbitMQ Queues

We want to restrict the data consumers consume daily while they're consuming messages from the queue. RabbitMQ monitoring has something to do with the number of messages from the queue and is not ...
Shreelakshmi Joshi's user avatar
0 votes
1 answer
21 views

pike.exception.StreamLostError python pika rabbitmq

I get pike.exception.StreamLostError: Stream connection lost: connectionResetError(10054... when I call connection.channel(): p = pika.ConnectionParameters('localhost') c = pika.BlockingConnection(p) ...
Rony Tesler's user avatar
  • 1,139
0 votes
0 answers
4 views

Can RabbitMQ allow Management UI to use OAuth and AMPQ connections to use Basic Auth?

I've recently configured a local instance of RabbitMQ to work with an OAuth provider for authenticating users to the Management UI. That part of the authentication config is working, however the ...
nealsu's user avatar
  • 398
0 votes
1 answer
42 views

'An existing connection was forcibly closed by the remote host' with Mass Transit and RabbitMQ

I have a fresh installation of RabbitMq and everything was working fine sending messages with Mass Transit and RabbitMQ. Suddently, this happened when I try to send a message ... RabbitMQ.Client....
xcasals's user avatar
0 votes
1 answer
19 views

what the default max length of rabbit queue

For any given queue, the maximum length (of either type) can be defined using a policy (this option is highly recommended) or by clients using the queue's optional arguments. In the case where both ...
winston's user avatar
  • 37
-1 votes
0 answers
12 views

I Encountered AMQP Connection Error everytime I run this code

#!/usr/bin/env python import pika, sys, os def main(): connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost')) channel = connection.channel() channel....
Komal Memon's user avatar
0 votes
0 answers
13 views

For installing a RabbitMQ cluster on CentOS 7.9, what is the maximum version supported? [closed]

For installing a RabbitMQ cluster on CentOS 7.9, what is the maximum version supported and what version are most people using? I installed version 3.8.18, but it is too old and erlang version ...
Earn 's user avatar
0 votes
1 answer
20 views

Kombu - RabbitMQ - Pytest - [Errno 104] Connection reset by peer

I'm using Kombu to connect to RabbitMQ, and found myself in some strange behavior. I have a generic producer function (see below), that I use throughout our code base. This works very well in most ...
Niels Uitterdijk's user avatar
0 votes
0 answers
22 views

Mechanism for managing faulty consumer in asynchronous messasing in microservices / modular monolith [closed]

I have modular monolith / microservices. One microservice has raised an event that something has happened. 3 other microservices are consumers. 2 of them have succesfully processed the request & ...
D. Nizio's user avatar
0 votes
1 answer
17 views

Fix error: Class %old_sound_rabbit_mq.producer.class% does not exist from OldSoundRabbitMqExtension.php

I'm trying to execute symfony project with a rabbitmq plugin. The problem it's when i execute the command: php bin/console rabbitmq:consumer -m 50 activity-logs. The response is: ...
Robert Blasco Villarroya's user avatar
-1 votes
0 answers
10 views

Handling SimpleMessageListenerContainer shutdown in Spring Boot

I'm using RabbitMQ with SpringBoot with spring-boot-starter-amqp. When something happens with Rabbit eg. restart, the SimpleMessageListenerContainer gots shutted down: ERROR 1 --- [enerContainer-4] o....
Danubian Sailor's user avatar
0 votes
0 answers
39 views

How to get the RabbitMQ Automatic Recovery to work with the C# library?

I'm trying to build a simple MQTT connection with the RabbitMQ C# library. The connection is working and data is transferred. Now the problem: If the RabbitMQ-Broker goes down temporarily, neither the ...
abones's user avatar
  • 1
-1 votes
0 answers
48 views

Cannot connect to rabbitmq with docker

I can connect to rabbitmq when I run the apps outside of docker with no issus. None of the specified endpoints were reachable ---> System.AggregateException: One or more errors occurred. (...
3xGuy's user avatar
  • 2,145
0 votes
0 answers
14 views

pika.exceptions.ConnectionClosedByBroker: (320, 'CONNECTION_FORCED - Node was put into maintenance mode')

I was getting this exception in production environment. pika.exceptions.ConnectionClosedByBroker: (320, 'CONNECTION_FORCED - Node was put into maintenance mode') currently I don't have any idea to ...
akshay's user avatar
  • 71
0 votes
0 answers
20 views

Consumer: Connection to broker lost. Trying to re-establish the connection Rabbit MQ and Celery

I have created a small Flask app in which I want to carry out a task in Celery with the help of RabbitMQ. I have installed and created the user in my Windows 10 system, but whenever I try to connect ...
ankit12's user avatar
0 votes
0 answers
12 views

Celery task workflow message exhausts rabbitmq default message size

I'm designing a celery task workflow that has task test_request_task, test_chord_callback_task, test_chain_of_chord_callback_task and test_chain_of_chords_task. I need to run task test_request_task, n(...
Mehedee Ahmed Siddique's user avatar
2 votes
1 answer
29 views

RabbitMQ.Client.Exceptions.OperationInterruptedException

I'm working on my student project related to Notification Brokers. As a sample our teacher provided us with the following repository: https://github.com/DeveloperStories/RabbitMQ. I selected Publisher ...
Alex's user avatar
  • 115
-3 votes
0 answers
30 views

Rabbitmq and SMTP do not send a email

I have a problem, there is no any error but the email is not sent. I have rabbitmq in docker. Every message goes to the queue but is not send. I tried to use two different email providers because I ...
kamilo432's user avatar
1 vote
1 answer
284 views

RabbitMQ closed connection on method CreateModel()

I'm trying to run Producer example from tutorials, but RabbitMQ closed connection with exception: Exception thrown: 'RabbitMQ.Client.Exceptions.OperationInterruptedException' in RabbitMQ.Client.dll An ...
DQuade's user avatar
  • 283
0 votes
0 answers
17 views

Handle retryable AMQP messages with DLQ

Disclaimer! Following code works. I would only ask about implementation correctness or other way (if exists) to solve my problem. Definitions some-domain-name.q.some-service.incoming-messages - this ...
Piotr Olaszewski's user avatar
0 votes
1 answer
20 views

RabbitMQ MassTransit batching competing consumers

I've set up a batch consumer of an event ExampleEvent and set it to have ConcurrencyLimit = 16, MessageLimit = 100, TimeLimit = 5 sec and grouping by ExampleEvent.GroupingKey field. This works fine ...
xLokos's user avatar
  • 69
0 votes
0 answers
9 views

In the confirm method of spring integrated rabbitmq, ack is always false

spring 5.17 rabbitmq 2.18 junit 4.12 problem When I test the confirm of reliable delivery of messages, I use topic mode to test. When I send a message to the switch, I call back confirm(...
朱宇龙's user avatar
0 votes
0 answers
19 views

Run RabbitMQ without default user being created

I am running single RabbitMQ instance. Because of uniformity, all queues, exchanges, bindings and users will be created from definitions.json file. My config: management.load_definitions = /etc/...
Fusion's user avatar
  • 4,957
0 votes
1 answer
21 views

How to send unacked messages to DLX after TTL?

I have rabbit queue my_queue which is configured with DLX sending messages to my_queue_dlx. A test with message-ttl works as expected. A message which stays in a queue for ttl and later moved to DLX ...
Aistis's user avatar
  • 3,645
0 votes
1 answer
21 views

RabbitMQ - What takes precedence, Message TTL for Queues or Per-Message TTL in Publishers

If I have created a queue via Queue Declaration: var args = new Dictionary<string, object>(); args.Add("x-message-ttl", 60000); model.QueueDeclare("myqueue", false, false, ...
PKCS12's user avatar
  • 398
0 votes
1 answer
21 views

How to mock RabbitAdmin class in JUnit

I'm trying to create a mock object for RabbitAdmin class in JUnit. @Mock RabbitAdmin rabbitAdmin; @InjectMocks MyOriginalClass classObj; The above is what I have declared. Mockito.when(rabbitAdmin....
Srigandan's user avatar
-1 votes
0 answers
32 views

RabbitMq Streams Client and C#

So my client who wants me to start using Rabbit MQ streams is still on .net 4.8. They wont be upgrading to anything else for a while since government systems are baselined to .net 4.8. The nuget ...
Waddaulookingat's user avatar

1
2 3 4 5
282