14,386 questions
1
vote
0
answers
51
views
Azure Function with RabbitMQ Trigger - Queue not found in localhost
For local development I want to connect my Azure Function to a locally running RabbitMQ instance and run everything locally. But the queue is not found, even though I made sure it exists (see ...
- 11
0
votes
1
answer
30
views
RabbitMQ Federation different vhost in two different instances [closed]
I have tried federation with a matching vhost on both sides works well.
as the doc says,
Typically, federation is used to connect remote clusters. However, it can also be used to move data between ...
- 81
0
votes
0
answers
27
views
QPID JMS OAuth Token Refresh
I am using Qpid JMS to connect to RabbitMQ using OAuth.
I have read about the Connection Extensions section of the Qpid JMS documentation, which describes how to update the token on a ...
- 11
1
vote
0
answers
33
views
Dynamically Change Concurrent Consumers - with Spring Cloud Stream and RabbitMQ binder
I have a Spring Cloud Stream consumer using the RabbitMQ binder configured:
spring:
cloud:
stream:
bindings:
input:
destination: myQueue
rabbit:
bindings:
...
- 21
0
votes
1
answer
84
views
What is the correct context to consume a RabbitMQ broker within the PHP/laravel ecosystem?
We have a system that captures telemetry data in real time. The broker we hire sends telemetry data in real time from the device they place inside our cars. This operation has been running for two ...
- 29
1
vote
1
answer
111
views
How can I completely and totally prevent retries using MassTransit and RabbitMQ?
I have a microservice using MassTransit to process messages off a RabbitMQ queue. However I am having a problem where upon an error, MassTransit retries processing the message and/or the message ...
- 340
0
votes
0
answers
50
views
MassTransit response to RabbitMQ timeout
I have a microservice consuming messages off a RabbitMQ queue using a MassTransit consumer. The problem I am having is that once a message is being processed, it is in a Not-Acknowledged state in ...
- 340
1
vote
0
answers
75
views
RabbitMQ Error: "PRECONDITION_FAILED - reply consumer cannot acknowledge" Code: 406
I'm trying to get a response from a webhook and send it to rabbitmq if it works, consume it with ack if not, with nack to repeat the webhook process for payments or document validations, but I'm not ...
0
votes
1
answer
27
views
MassTransit consume direct queues per type with non-generics
TasksDispatcher pushes tasks into direct queues per JobType enum:
public async Task DispatchAsync(Job job, CancellationToken ct)
{
using var scope = this.scopeFactory.CreateScope();
var ...
- 2,966
0
votes
1
answer
61
views
RabbitMQ received bytes are invalid
I've a rabbitMQ implementation (C# with RabbitMQ.Client 7.1.12 nuget) where we send a short json to a queue. But when the receiver gets the queue item sometimes (approximately 1 on 5) the byte array ...
- 2,961
0
votes
0
answers
83
views
How to handle Nest.JS DLQ and EXCHANGE?
I am creating a Nest.js micro service application. I have 5 micro services. And I am using RabbitMQ to communicate with them. I am using the Transport.RMQ. My challenge is when as producer i pass the ...
- 455
0
votes
0
answers
43
views
MassTransit JobConsumer never hit
I have an ASP.NET Core solution that contains 2 services (each using MassTransit) and a common project that has the configuration part for both of the services.
The common project contains the ...
- 514
0
votes
0
answers
133
views
RabbitMQ error connection in Spring Application - getsockotp
I’m building a Spring Boot application that uses RabbitMQ.
Here is my current setup:
application.properties
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
...
- 1
1
vote
0
answers
81
views
Laravel RabbitMQ worker not processing batch
We are using a RabbitMQ worker (https://github.com/php-enqueue/enqueue-dev/tree/master) on our Laravel 11 system to process job batches. At the end of each job, it checks if any more jobs need adding ...
- 11
0
votes
0
answers
58
views
Hot Chocolate GraphQL Subscription Provider RabbitMQ not connecting
I am using the Hot Chocolate GraphQl library to do real time pub/sub messaging, this works if i create the RabbitMQ connection and channel without using the Hot Chocolate library using the same .Net ...
- 43
0
votes
0
answers
42
views
WiX skip uninstall registry set to 1 and during upgrade uninstall all unnecessary stuff
I have a problem during my WiX upgrade - after normal installation of my program for example in version 1.0 I am installing all necessary stuff like RabbitMQ, Erlang and so on but if I want to upgrade ...
- 55
2
votes
1
answer
74
views
How to prevent queue from being deleted?
I am new to RabbitMQ and having trouble with my queue being auto deleted. I do not want anything to be auto deleted. I have set the queue to not delete but every time I run the app the queue is ...
- 570
0
votes
0
answers
56
views
RabbitMQ - Consume a Large Volume of Messages from a Queue withou ACK
I would like to read a large volume of messages from a RabbitMQ queue, but negatively acknowledge (NACK) them. Some other consumer will ACK them and do work later.
I have 100,000 messages in a queue. ...
- 1,199
0
votes
1
answer
85
views
MassTransit RabbitMQ annoying unwanted fanout exchange
From what I read:
Direct exchange - for commands,
Fanout exchange - for events (publish/subscribe).
Since official MassTransit documentation isn't very good, and video tutorials aren't in the format ...
- 2,966
0
votes
0
answers
68
views
Celery and AWS MQ Disconnections
I set up a celery + beat containers in ECS and used AWS MQ as the broker. However, my setup seems to be very prone to disconnections, where celery workers are suddenly disconnected from MQ.
I end up ...
- 79
2
votes
1
answer
271
views
Is it possible to use retries and deadletter queues in Celery?
I have successfully got Celery to put failed tasks onto deadletter queues in RabbitMQ, thanks to this answer https://stackoverflow.com/a/46128311/736221 and this article https://medium.com/@hengfeng/...
- 687
0
votes
0
answers
83
views
How to use RabbitMQ in a windows service
I'll start with the basics.
I am creating an app and want to split it out to microservices. Because I want the microservices to run when the computer is turned on, in the background, regardless of ...
- 570
0
votes
0
answers
38
views
RabbitMQ Channel Pooling
I have a service with 5 RabbitMQ workers, each running in its own process. Currently, every worker creates its own connection and channel, resulting in 5 connections and 5 channels. To reduce the load ...
- 29
0
votes
0
answers
57
views
Spring Boot microservice not reading from rabbitMQ
I have a rabbitMQ container running from docker compose:
services:
rabbitmq-demo:
image: rabbitmq:3.13-management # Using management tag for easier monitoring
hostname: rabbitmq
ports:
...
- 2,477
0
votes
0
answers
151
views
/snap/core20/current/lib/x86_64-linux-gnu/libpthread.so.0: undefined symbol: __libc_pthread_init, version GLIBC_PRIVATE
I am trying to find a solution for the symbol lookup error. Here are the details of my setup.
Software Stack:
Ubuntu 25.10
snapd 2.67.1+25.04 amd64
git version 2.48.1
microk8s 1.32
krew-linux-amd64
...
- 11
0
votes
0
answers
22
views
Why are unused queues associated to topics not removed in RabbitMQ 4.1.0?
I am using RabbitMQ version 4.1.0.
I am using topic exchange.
My problem is: a new queue related to a given topic is created. But sometimes the previous queue is not deleted, and messages are still ...
- 381
0
votes
1
answer
47
views
Two MassTransit consumers consuming the same request at the same time?
I know this should not be possible, so I'm thinking we configured something terribly wrong. We were getting 409(Conflict) errors from a 3rd party API we are using and trying to test locally, if I put ...
- 13
0
votes
0
answers
40
views
How are the queues related to topic created in RabbitMQ with AMQP 1.0?
I am using RabbitMQ 4.0.4 with AMQP 1.0 in node via the rhea and rhea promise libraries. I am using topics.
How are the queues related to topics are created and deleted in RabbitMQ with AMQP 1.0 with ...
- 381
1
vote
1
answer
83
views
Spring boot using undefined for x-queue-type instead none
Dependencies
java: 17
spring-boot: 3.2.12
spring-cloud-starter-stream-rabbit: 4.1.2
bitnami/rabbitmq: 3.13.7-debian-12-r2
Error
ERROR [,,,] 1 --- [.43.83.237:5671] o.s.a.r.c.CachingConnectionFactory ...
- 1,404
0
votes
0
answers
30
views
Producer Successfully Sends Messages, but Some Are Lost Before Reaching Consumer (amqplib + RabbitMQ)
We are using amqplib in a TypeScript/Node.js application to publish messages to RabbitMQ using sendToQueue, and although it returns true and we’ve wrapped it with ConfirmChannel and await channel....
- 11
0
votes
0
answers
36
views
backgroundservice rabbitmq consumer waiting
I am implementing an aspnet backgroundservice rabbitmq consumer that subscribes to push events from the server:
protected override async Task ExecuteAsync(
CancellationToken stoppingToken)
{
...
- 982
0
votes
0
answers
42
views
RabbitMQ Configuration Entry Encode / Decode problem
I am working with RabbitMQ v3.12.0 which is running on Erlang v26.0.1. on a Windows 10 machine. The problem is that I am unable to successfully apply encrypted configuration entries. To simplify the ...
0
votes
1
answer
60
views
NestJS @EventPattern with RMQ topic exchange does not create binding (no bindingKeys, custom exchange)
I’ve created a service in NestJS and connected it to RabbitMQ.
The connection is established successfully, but I don’t receive any messages unless I manually add a binding in the RabbitMQ Management ...
- 19
1
vote
0
answers
33
views
Why EventingBasicConsumer can't process RMQ messages in parallel, although prefetch =100
I'm using C# RabbitMQ.Client Lib to process RMQ message.
I have set the prefetch to 100, but the EventingBasicConsumer still process the message one by one. why it can't raise 100 event at same time?
...
- 11
0
votes
1
answer
72
views
How to know which is primary host in Clustered RabbitMQ environment
How do I know which is the primary host of RabbitMQ using API/CLI in a clustered environment.
Below URL giving me the list of hosts, but unable to get the primary from it...
curl -sL -u guest:guest -H ...
- 9
0
votes
0
answers
66
views
RabbitMQ block ports
unfortunately, after connecting RabbitMQ, I can't open my app on any port. After running, my app is up, but while RabbitMQ is running in Docker, I can't open Swagger on localhost with any port that I ...
- 21
0
votes
0
answers
42
views
Can I reshuffle the order of messages in RMQ?
I am using java based application to publish & consume RabbitMq services for message exchanges.
So architecture is pretty simple
Java application which produces & consume messages from RMQ ...
1
vote
0
answers
49
views
Spring Data JPA - Transaction silently rolled back when saving TaskHistory with Task relationship
I'm implementing a task history feature in a Spring Boot application where each status change should be recorded in a task_history table. However, I'm getting transaction rollback errors when trying ...
0
votes
1
answer
60
views
Spring Cloud Stream RabbitMQ: NoUniqueBeanDefinitionException for ConversionService and cannot use @Primary
Question:
I’m building a Spring Boot application that uses Spring Cloud Stream with the RabbitMQ binder. My project pulls in several dependencies—Spring MVC, Spring Cloud Stream, Resilience4j (circuit ...
- 571
0
votes
1
answer
151
views
How to use RabbitMQ Publisher Confirms and Returns for Reliable Message Delivery
I'm using RabbitMQ with Spring AMQP and want to ensure reliable message delivery from the producer to the RabbitMQ broker. To achieve this, I've enabled Publisher Confirms and Publisher Returns.
...
- 23
-1
votes
1
answer
131
views
Azure function does not have Rabbit MQ trigger
I am using Python to develop Azure function. I have tried and successfully ran the HTTP template of Azure function locally on my PC.
However, now I am trying to run Azure function app with Rabbit MQ ...
-1
votes
0
answers
52
views
RabbitMQ cluster running out of memory
I’m running a RabbitMQ cluster (version 3.13.7) with three nodes, and I’m trying to understand why the cluster is running out of memory after a few weeks of operation.
From the RabbitMQ metrics, I can ...
- 23
0
votes
1
answer
125
views
Azure Function with RabbitMQ: output multiple messages
I have an Azure Function made in Java, which is triggered by RabbitMQ messages on a specific queue.
My problem is that I need to output two different messages, one in the middle of the function's code ...
- 1,614
0
votes
0
answers
29
views
Second Celery task triggered inside first task stays pending intermittently and never executes
I’m using Celery with Redis and RabbitMQ as brokers, and Flower for monitoring. I have an API endpoint to upload documents, which triggers a first Celery task to process the initial batch.
Inside this ...
0
votes
0
answers
24
views
rabbitmq python pika stop consuming if queue is empty
I have simply code retrieving messages from queue but keep waiting for new messages
how can I continue execution after all messages retrieved ?
import pika, sys, os
def main():
connection = pika....
0
votes
1
answer
183
views
How to effectively use a rabbitMQ channel in ASP.NET application?
I have a web application where the result of calling an endpoint will publish a message to rabbitMQ. This says a channel object is not thread-safe, but a channel should be long lived. I have come up ...
0
votes
1
answer
93
views
How can I set up RabbitMQ in .NET Minimal Web API to then be able to use it in my services?
I want use AMQP connection string. I want to create a single shared connection (and channel per app lifetime to avoid resource exhaustion.
- 33
0
votes
0
answers
65
views
celery worker not consuming tasks from rabbitMQ queue
I have a queue in RabbitMQ broker called queue-ktm of type quorum. There are tasks pushed to this queue and available.
I run a celery worker to consume from this queue with following configuration:
...
- 4,161
0
votes
0
answers
29
views
Avoid multiple error responses due to retry logic in Spring RabbitMQ listener with transactional setup
I have a microservices architecture where services communicate via RabbitMQ. In one microservice (let’s call it EventService), I publish a message and wait for a synchronous response from another ...
- 122
-2
votes
1
answer
128
views
How to share files between two microservice in both cloud and on-prem setups? [closed]
In my existing monolith application, I generate files that need to be sent as email attachments. I've started moving to a microservices architecture, where an event is raised via RabbitMQ to trigger ...
- 79