2,528 questions
0
votes
2
answers
17
views
How to create quorum queue in RabbitMQ using rhea.js
I am able to create classic queue but not quorum queue in RabbitMQ 4.0 using rhea.js and AMQP1.0
1
vote
1
answer
214
views
.NET clients cannot see Azure Service Bus messages created by node
I have a node server that is posting messages to an Azure Service Bus topic using the rhea client. The system reading the messages is a .NET console app using the AMQP.NET Lite library. Both clients ...
- 34.6k
0
votes
1
answer
104
views
setTimeout when trying to close amqp library channel and connection skips catch block
Fairly sure this is nodejs noobish thing, but I've the following bit of code:
const amqp = require('amqplib');
const fs = require('node:fs/promises');
exports.publishRabbitMQResults = async function ...
1
vote
1
answer
103
views
Proton-J2 AMQP 1.0 Receiver that filters messages?
I'm investigating writing a systems integration using AMQP and looking to copy some common system integration patterns used with JMS based APIs. That includes a message-consumer that filters messages ...
0
votes
0
answers
62
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,487
0
votes
0
answers
49
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 ...
- 391
0
votes
0
answers
80
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,171
0
votes
0
answers
43
views
Renew authentication token when using Spring AMQP with OAuth IAM
I am using OAuth token for access RabbitMQ cluster. According to the RabbitMQ OAuth plugin documentation connection must bu updated when the token is expired.
Does Spring AMQP support update-secret ...
- 11.4k
0
votes
1
answer
73
views
Is it possible to create a Queue in Reactive Messaging AMQP Connector without a broker.xml file?
I am following the documentation about Reactive Messaging AMQP Connector and I have a created a producer as well as a consumer class. I have set the needed properties as defined in documentation, in ...
- 566
0
votes
0
answers
44
views
Channel closing when application is restarting
When my application gets an unexpected type of exception I use
channel.basicNack(tag, false, true);
SpringApplication.exit(context);
to stop the app and put the message in its original queue.
After ...
- 11
0
votes
1
answer
232
views
Are all the queues in Rabbit MQ with AMQP 1.0 based on a topic exchange temp?
My team and I are currently working on the migration from AMQP 0.9 to AMQP 1.0 in RabbitMQ. We are using proton for AMQP 1.0, and we used Pika for AMQP 0.9. We are using Blocking Connection.
In AMQP 0....
- 391
0
votes
2
answers
154
views
Qpid Proton Python release(delivered=True) not triggering redelivery in ActiveMQ Artemis (2.40.0)
I'm using Apache ActiveMQ Artemis 2.40.0 as the broker and Qpid Proton Python 0.39.0 (python-qpid-proton) as the AMQP 1.0 client.
The goal is to have messages redelivered up to a configured limit (max-...
1
vote
3
answers
164
views
AMQP 1.0 client libraries for Android
I'm trying to implement an AMQP 1.0 client in my Android app, but I haven't been able to find a working solution so far.
I have already tried using the Apache QPID ProtonJ2 and Apache QPID JMS ...
- 1,512
1
vote
0
answers
65
views
PHP and RabbitMQ 504 Gateway Time-out error in consumer
My class consumer, wait message from Rabbit:
<?php
namespace App\Infrastructure;
use App\Application\Interfaces\BankServiceInterface;
use App\Application\Interfaces\ConsumerInterface;
use App\...
0
votes
0
answers
170
views
RabbitMQ vhost exists in `list_vhosts`, but can't be found by `delete_vhost` command. How do I delete it?
When I list the vhosts, the vhost xms clearly shows up.
$ sudo rabbitmqctl list_vhosts
Listing vhosts ...
name
/
xms
xms_test
But when I try to delete it, it seems to not exist
$ sudo rabbitmqctl ...
- 15.7k