2,533 questions
0
votes
0
answers
6
views
Amqp nodejs disconnect event
I'm using amqp in my nodejs scrapping service. Sometimes I get random disconnects and when it autoreconnects, it starts a new whenConnected promise but the previous is still running so my app mess up:
...
- 119
0
votes
0
answers
46
views
quarkus-messaging-amqp CloudEvent with extentions
I am creating a Quarkus service that accepts SOAP request and puts the data in a AMQP queue following CloudEvent specification. I want to add an additional metadata parameter (extension), but in the ...
- 45
0
votes
0
answers
19
views
AMQP queue headers disappearing after the message is published
in a circuit breaker context, we are trying to publish rabbit messages in a "headers" exchange.
We're using the AMQP publish connector (version 1.7.4) in mule 4.4.0, and we're trying to ...
- 73
1
vote
0
answers
43
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
17
views
Spring AMQP RabbitMQ sendAndReceive with isChannelTransacted=true
I am trying to make use of an RPC call to RabbitMQ using Spring amqp's convertSendAndReceiveAsType.
We normally use convertAndSend in regular async communication to Rabbit and make use of ...
- 82.1k
0
votes
0
answers
18
views
RabbitMQ Exception (552) Reason: "an AMQP header cannot be bigger than 512 bytes"
I'm encountering an issue with RabbitMQ where I get the following error:
Exception (552) Reason: "an AMQP header cannot be bigger than 512 bytes"
Environment Details:
RabbitMQ version: 3....
- 1
0
votes
0
answers
33
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.6k
0
votes
0
answers
26
views
How can I configure (AMQP) RabbitMq to effectively serialize complex object types?
I want consume a message object of type
Map<Integer,List<Object>>,
but the
rabbitmq
was finding it difficult to properly serialize the object. I am sorry if this solution has been ...
- 1
0
votes
0
answers
55
views
How to propagate trace context with Dapr PubSub RabbitMq
I have two services talking to each other through RabbitMq.
Service A publishes messages directly to RabbitMq and Service B uses Dapr with the RabbitMq pubsub component.
Both services are instrumented ...
- 1,089
0
votes
1
answer
81
views
Azure Service Bus and Azure Container Apps - Redeploy fails as there alread is a client using tha sub against that topic
I have a (Java 21/EE10 on WildFly 33) container that connects to Azure Service Bus using JMS 2.0 (Hence ESB Premium Tier).
All is well.
However when redeploying (or even restarting) the POD the @...
0
votes
1
answer
75
views
Spring RabbitMQ - RPC - CorrelationId not matching - TopicExchange - Client- Server - model
I have Spring boot - RabbitMQ app. The exchange used is topicexchange.
public static final String RPC_REQ_QUEUE = "req.queue";
public static final String RPC_RES_QUEUE = "res.queue"...
- 1,016
1
vote
1
answer
404
views
How can I keep alive Azure Service Bus client and sender instances for more than 10 minutes in Python SDK?
I'm currently working on integration of Azure Service Bus queue and custom gateway service. Every time service receives an event, it should send message to the dedicated queue.
I've managed to ...
- 11
0
votes
2
answers
112
views
How to publish messages to a topic in Solace broker using AMQP
We have a Quarkus app that uses the smallrye-amqp connector. I have the following code for publishing messages to a topic.
@ApplicationScoped
public class InsightLifecycleObserver {
public static ...
- 175
0
votes
1
answer
103
views
_ITERATOR_DEBUG_LEVEL mismatch for one file in project
I am trying to compile my C++ project in Visual Studio Community 2022 (v143) with amqpcpp library but with no success.
I have built amqpcpp library file using instructions on their github page and ...
- 45
0
votes
0
answers
147
views
Illegal access exception when using AMQP header in Mule 4 for JSON format
I'm trying to use a header from AMQP in my Mule flow inside a Transform Message component, but an IllegalAccessException is thrown ONLY if output is JSON (not Java).
What am I doing wrong?
<amqp:...
- 3
2
votes
1
answer
162
views
Spring-boot RabbitMQ rotate credentials
Background-info
I'm using the spring-boot-starter-amqp dependency to connect to RabbitMQ.
In my application.yaml I have:
spring:
rabbitmq:
host: <host>
port: 5672
username: <...
- 53
0
votes
1
answer
108
views
ActiveMQ Artemis redelivery delay using AMQP annotations
In artemis when using AMQP, there is an annotation to indicate that you wish for the message to be delivered at a later time called x-opt-delivery-time https://activemq.apache.org/components/artemis/...
0
votes
0
answers
499
views
Unable to install symfony/amqp-messenger due to amqp issue
I've been trying to set up the PHP AMQP extension on WAMP server with PHP 8.2. I've placed rabbitmq.4.dll, and rabbitmq.4.pdb in the PHP root and php_amqp.dll in the ext folder. However, I keep ...
- 97
0
votes
0
answers
216
views
Messages not reaching RabbitMQ queue when sent from ESP32 via MQTT, but can be consumed live
I am running a script on an ESP32 board which is attempting to publish data to a RabbitMQ server using the PubSubClient library.
The client is defined on the ESP board as follows:
WiFiClient espClient;...
0
votes
1
answer
86
views
Cloud-to-on-premises communication scaling in RMQ
We have an application that consists of two parts: a cloud backend API and an on-premises service that the client installs. The communication between the service and the client is done via a RMQ ...
- 2,818
0
votes
1
answer
38
views
How to calculate roundtrip-time using JMeter and AMQP Plugin?
I would like to test my RabbitMQ implementation with JMeter. For my test, the time that a message needs from the publisher to the consumer is interesting.
Is it possible to calculate this with JMeter? ...
0
votes
0
answers
99
views
Connect to amqp with jwt token
I use @cloudamqp/amqp-client library and set up rabbitmq server to use oauth2, how can I use jwt to connect to broker via websocket?
I tried make this - connection closed: ACCESS_REFUSED - Login was ...
- 358
0
votes
0
answers
95
views
Integrate AMQP-CPP with CMakeLists
I'm building a project with RabbitMQ but still can not build properly.
I've installed the necessary pkgs like AMQP-CPP and add the static lib libev into my folder.
Anything wrong with my CMakeLists?
...
- 347
0
votes
0
answers
50
views
Unable to send message via Apache Qpid Dispatcher to RabbitMQ
I am trying to use Apache Qpid Dispatcher as a stand alone router to route messages to a Rabbit MQ broker using AMQP 1.0. The sending of the message is done via a Java application using Apache Qpid ...
- 1
0
votes
1
answer
64
views
How to retreive message body on fail on rabbitmq
In Java, with Spring AMQ:
I'm looking for a way to retreive the message body when the message is sent on a exchange that does not exist.
With the confirmCallback, I can get the correlation data ID, ...
0
votes
0
answers
62
views
Symfony Use Mercure with RabbitMQ ? Possible?
I would like to use mercure with rabbitmq, use rabbitmq instead of mercury hub. Is this possible ? Maybe in Async
I tried this little code but it doesn't work
My controller
$update = new Update(
...
- 21
1
vote
1
answer
1k
views
EventProcessorClient fails to start processing Eventhub messages - Creation of RequestResponseAmqpLink did not complete in 0 milliseconds
I created an Event hub processor in .net, followed that example:
https://github.com/Azure/azure-sdk-for-net/blob/Azure.Messaging.EventHubs.Processor_5.11.2/sdk/eventhub/Azure.Messaging.EventHubs....
- 23
1
vote
0
answers
83
views
Accessing RabbitMQ using WebStomp (stompjs) works on localhost only
I´m using RabbitMQ broker with multiple clients via AMQP (.NET WebAPI, MAUI...) working with no issues connecting to broker on remote server (Azure VM). But for React web client we have to use ...
- 11
0
votes
1
answer
38
views
What is the difference between spring.rabbitmq.publisher-returns=true and spring.rabbitmq.template.mandatory=true?
What is the difference between spring.rabbitmq.publisher-returns=true and spring.rabbitmq.template.mandatory = true?
When one of these two configurations is set to true, when a message is sent to ...
0
votes
1
answer
65
views
How to translate AMQPComponent XML bean to Java bean for Camel with Spring Boot 3
I have an old Camel 2 with the old Spring Framework 4 app. It has been working for many years. I am upgrading it to Spring Boot 3 and Camel 4.5.0.
It has an amqp XML bean.
<bean id="alarmq&...
- 21.7k
0
votes
0
answers
68
views
Problem "Connection lost" in AMQP-CPP with boost asio
I use the AMQP-CPP library (a C++ wrapper for RabbitMQ) to create a RPC server and several clients. For event loop I use boost Asio and run it inside a std::thread.
I implemented class-wrapper ...
0
votes
0
answers
107
views
rhea amqp ActiveMQ Artemis connection error
I am starting Apache ActiveMQ Artemis 2.32.0 using a Docker container:
docker run --name activemq-artemis-2.32.0-alpine -p 61616:61616 -p 8161:8161 -p 5672:5672 --rm apache/activemq-artemis:2.32.0-...
- 542
0
votes
0
answers
36
views
Troubleshooting topic exchanges in php-amqplib
I'm a beginner with RabbitMQ and having some difficulties setting up topic exchanges. I'm working with two scripts: emitter.php and receiver.php. The receiver.php script will be replicated using ...
- 11
0
votes
0
answers
20
views
RabbitMQ Connection Failure after adding google auth dependency
After adding the following dependency
compile "com.google.auth:google-auth-library-oauth2-http:'1.23.0'"
to build.gradle all integration tests related to RabbitMQ failed with a connection ...
- 1
0
votes
1
answer
149
views
Rabbitmq RPC(request-reply) using springboot
i want to implement the request-reply pattern for microservices communication using RabbitMQ. However, the issue is that every internal call creates a new queue, and by default, the queue size in ...
0
votes
1
answer
100
views
How to Configure ActiveMQ Artemis Server to Interoperate Messages Across Different Procotols AMQP and Openwire
I have an ActiveMQ Artemis server that is configured like so:
public static void updateConfig(Configuration config) {
try {
config.setPersistenceEnabled(false)
....
- 946
0
votes
1
answer
125
views
RabbitMQ creating multiple connections
Here is the producer code:
import * as amqp from "amqplib";
export default class Producer {
channel;
async createChannel() {
const connection = await amqp.connect("...
- 2,649
1
vote
1
answer
826
views
How to configure ActiveMQ Artemis to use AMQP 1.0 and other protocols with Java
I have an ActiveMQ Artemis server which works fine. I now would like to enable AMQP on the server for a node application using pub-sub. While my node pub subs are able to connect to it they neither ...
- 946
1
vote
1
answer
126
views
Exception javax/management/openmbean/CompositeData using AMQP-client in WildFly built-in ActiveMQ Artemis server
I've been using a QPID C++ client (AMQP) with WildFly 23.0.1 for a while and there is no issues with it.
Now I want to use a newer version of WildFly (30+) and found a major problem: QPID client is ...
- 13
0
votes
0
answers
86
views
Exist some way to extract the correlation-Id property from of a MQ message using AMQP?
I have a microservice that is subscribed to a topic and receives messages using the AMQP protocol. This microservice reads the correlationid value in order to set the response with this same ...
0
votes
1
answer
317
views
RabbitMQ: round-robin for multiple consumer
Project consist of three main things:
Producer (device) send data to broker on MQTT protocol
RabbitMQ broker
Consumer (spring AMQP) for communication between application and broker.
(device MQTT ...
- 159
1
vote
1
answer
238
views
How to use php-amqplib to connect to ActiveMQ Classic Docker image
I am trying to create a custom command that should consume messages from an ActiveMQ Classic queue. I am using php-amqplib, and I created my custom connector and ActiveMQServiceProvider. I am getting ...
- 119
0
votes
0
answers
157
views
How to reconnect to RabbitMQ after the RMQ goes down
I have a python code that connects to RMQ and consumes messages. I just noticed that when the RMQ goes down my code just hangs at the close connection (inside aioamqp library) and stuck there and the ...
- 5,219
0
votes
0
answers
150
views
How to put rabbit request into Confirm mode, not entire channel into Confirm mode
I just want Confirm mode for a single request, not to affect the entire channel (other requests made with that channel).
This bit of code modifies the channel:
/// Enable Confirm mode
if err := ch....
- 100k
0
votes
1
answer
261
views
Encountered sasl exception when connecting to Solace topic with AMQPLite dotnet library(AMQP 1.0)
I am suffering an error when I tried to send/publish the messages with AMQP in my C# code.
Below is the error:
{error(condition:amqp:not-implemented,description:sasl-mechanisms(sasl-server-mechanisms:[...
- 41
0
votes
1
answer
295
views
Problem with multiple consumers using the same fully qualified queue name
I have an address and a queue defined as following in broker.xml:
<address-settings>
...
<auto-create-queues>false</auto-create-queues>
<auto-create-...
- 365
0
votes
2
answers
414
views
Connection to RabbitMQ Durable Queue fails over AMQP 1.0 protocol - Protonj2
Found Solution:- See solution at the end of this question.
I am trying to connect my AMQP 1.0 consumer (using Apache ProtonJ2 library). But my connection fails with following error
org.apache.qpid....
- 950
0
votes
1
answer
678
views
AMQP RabbitMQ Consumers being killed and aren't restarted
I'm trying to fix a tricky issue here in a Springboot RabbitMQ AMQP scenario.
I've got multiple queues with concurrency set to 2:
The application starts and consumes messages normally. I've got 3 ...
- 402
0
votes
0
answers
166
views
How to consume RabbitMQ messages using a terminal or tool?
I have the following rabbitmq configuration in a Spring Boot microservice:
application.yml:
rabbitmq:
addresses: app-test.company.com:5671
vhost: app-test
username: user
password: ******
...
- 12.1k
0
votes
0
answers
512
views
Is it possible to set cmake flags for conan required libraries?
I am trying to set the -DAMQP-CPP_LINUX_TCP=ON cmake flag for amqp-cpp/4.3.26, a required library in my conanfile. Is it possible to set cmake flags for required libraries via conan? If so, how?
I ...