2,533 questions
0
votes
0
answers
16
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
28
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,079
0
votes
1
answer
65
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
69
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"...
- 996
1
vote
1
answer
215
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
73
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
75
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
94
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
128
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
100
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
323
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
159
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
65
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,819
0
votes
1
answer
36
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
84
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
60
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?
...
- 337
0
votes
0
answers
44
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
54
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
52
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
727
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
59
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
35
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
59
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.6k
0
votes
0
answers
59
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
91
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-...
- 496
0
votes
0
answers
33
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
18
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
127
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
93
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)
....
- 926
0
votes
1
answer
112
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
661
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 ...
- 926
1
vote
1
answer
120
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
70
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
287
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
205
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
124
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,089
0
votes
0
answers
148
views
Laravel Queue RabbitMQ: Jobs not getting added to the queue when using Quorum queue type
I'm encountering an issue with Laravel Queue RabbitMQ when using the quorum queue type. Here's the setup:
Laravel version: 10
Package: [vyuldashev/laravel-queue-rabbitmq]
Queue type: Quorum
Issue: ...
0
votes
0
answers
395
views
Shopware 6 - Symfony\Component\Messenger\Bridge\Amqp\Transport\Connection::ack(): Return value must be of type bool, null returned
I am struggling to understand why this is not working.
Standard messages queue works just perfect. All custom queues are not.
I can proccess 1 item at the time and then the process dies with this ...
0
votes
0
answers
124
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....
- 99.4k
0
votes
1
answer
209
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
0
answers
72
views
Open spark readstream to Amqp provider
We are using Azure Service Bus and Databricks. We would like to store messages coming in to Service Bus in Databricks. We are using DLT pipelines in Databricks, which return a spark read or readStream ...
- 4,777
0
votes
0
answers
57
views
Exception with Transaction Reaper
We have a spring boot app running in Prod and this wierd exception below repeated in the logs, do anyone has idea? why it happens?
2024-01-11 14:14:48,759 WARN ? [Transaction Reaper] ARJUNA012117: ...
0
votes
1
answer
216
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-...
- 355
0
votes
0
answers
65
views
AMQP 1.0 + RabbitMQ - Default Auto-Delete property not set for server named queue when receiver connects to exchange without queue address
I am working on a scenario where my receiver connects to RabbitMQ over AMQP 1.0 using protonJ2 library.
The address to connect contains exchange name but not the queue name. Queue address is kept ...
- 950
0
votes
2
answers
376
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
564
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
142
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: ******
...
- 11.9k
0
votes
0
answers
429
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 ...
0
votes
0
answers
65
views
how many connections to a AMQP can one application have?
I've read some official material on the differences of channels from connections:
https://www.rabbitmq.com/connections.html
https://www.rabbitmq.com/channels.html
It says that channels should be ...
- 113
0
votes
2
answers
423
views
Username and password to connect to the C# library on IBM MQ
I'm on a mission to configure and test IBM MQ at my work. With that, I implemented a library in the C# language using AMQP.Net Lite to connect to IBM MQ and send and receive messages. However, even ...
- 757