Questions tagged [amqp]

AMQP is an open messaging standard. It defines a wire-level protocol and semantic framework for high performance enterprise messaging. If you're using a specific broker (ex: [rabbitmq]) then the AMQP tag may be redundant. AMQP should not be confused with Apache[ActiveMQ]

Filter by
Sorted by
Tagged with
-1 votes
0 answers
16 views

RedHat AMQ and Spring Boot 3 (Java 17)

I am faced with a new project where we require to use message queues in Spring Boot 3 microservices, and for which our customer offered us to use RedHat AMQ as their approved solution: we initially ...
usr-local-ΕΨΗΕΛΩΝ's user avatar
0 votes
0 answers
23 views

Rust axum connect to RabbitMQ

I have a problem with forwarding a RabbitMQ connection via with_state When I create an instance, Rmq channel.is_open() returns true (it returns the same thing in the main.rs file), but in the handler ...
Ilya bw's user avatar
0 votes
2 answers
77 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 ...
Leomar de Souza's user avatar
0 votes
1 answer
53 views

How to implement ConnectionFactory#setMaxInboundMessageBodySize in SpringBoot 2.7.15?

I am trying to increase the body-size limit of the inbonund amqp-messages. I have a Cloud-Foundry Springboot 2.7.15 application. My class currently looks like this: @Configuration public class ...
BlueIce's user avatar
  • 13
0 votes
2 answers
243 views

Spring Boot RabbitMQ attempt to deserialize unauthorized class exception

I use RabbitMQ in a Spring Boot project: sender @Component @AllArgsConstructor public class UserSender { private final RabbitTemplate rabbitTemplate; public String send() { User user ...
Mingfei's user avatar
  • 1,499
0 votes
1 answer
26 views

RMQ - 'configure access to queue refused' with readonly user attaching to queue (AMQP 1.0)

I get the error: "ACCESS_REFUSED - configure access to queue 'xxx' refused for user" when trying to consume an existing queue using the AMQP 1.0 plugin in RabbitMQ. The user has readonly ...
ajins's user avatar
  • 1
0 votes
0 answers
43 views

Thread Safe JAXB unmarshaller in rabbitmq listener java

I use jaxb unmarshaller in rabbitmq listener method with one quee multiple consumer . As you know jaxb unmarshaller is not thread safe so my unmarshalled object different from orginal message. How can ...
bkiyak's user avatar
  • 1
0 votes
0 answers
39 views

ModuleNotFoundError inside installed amqplib package

I have test project that uses amqplib. It is abandoned but it is still in use. I created virtual environment for this project last year and run it on Ubuntu 18 + Python 3.8 and it works fine Couple ...
Aleks Lee's user avatar
  • 136
1 vote
0 answers
68 views

Can I set custom ports for a ingress-nginx-controller by terraform/helm?

I need to expose port 5672 on nginx-ingress-controller externally. In other words I want have that configuration on nginx-ingress-controller svc for custom forwarding rule on LB. spec: ports: - ...
Jarek Skoczeń's user avatar
0 votes
0 answers
27 views

How to redeliver messages to consumer, when it reconnects after sometimes in rabbitmq?

Initially only producer is connected and consumer( CTRL+C, intentional ) somehow fails to connect to RabbitMQ server, Meanwhile producer have sent 4 consecutive messages to exchange-topic/server, Will ...
sunilsalat's user avatar
0 votes
0 answers
31 views

AMQPCPP Consumer And publisher don't create exchange and queues

Message Not Consumed:When you run my_publish to publish a message and then run my_consume to consume messages, the messages are not consumed as expected. Steps Taken to resolve the issue & ...
moumout's user avatar
1 vote
0 answers
66 views

Solution for (504) Reason: "channel/connection is not open" in Golang amqp

We have a client & consumer running in Golang. After certain time, unexpectedly the connection is dropped without any error on consumer side. And with dropped connection, when we try to publish a ...
Dharmang Solanki's user avatar
0 votes
0 answers
49 views

Subscribing to ActiveMQ Artemis queue from .Net app using ActiveMQ.Artemis.Client

I'm trying to pull messages from a durable queue (multicast under an address) in ActiveMQ Artemis from a .Net application using ActiveMQ.Artemis.Client. ActiveMQ Artemis is on a remote server, but I'm ...
BenW's user avatar
  • 829
0 votes
0 answers
102 views

Publish to Azure Service Bus Topic with AMQP using username and password

I'm dealing with a system implemented in .Net using AMPQ to publish messages to an ActiveMQ Artemis instance using a username and password, along with host, port, and protocol, e.g.: amqps://guest:...
BenW's user avatar
  • 829
0 votes
1 answer
82 views

How to ensure order of events in message groups with amqp reactive-messaging and quarkus?

Is there a way to make amqp reactive-messaging and quarkus ensure order of events in message groups? There is my implementation next, and I can see that inbox-events subscriber can observe multiple ...
Kirill Byvshev's user avatar
0 votes
0 answers
31 views

Jmeter | reply-code=406, reply-text=PRECONDITION_FAILED - inequivalent arg 'x-max-priority' for queue

I'm getting below error while pushing a message to queue. Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=406, reply-...
Akshay_Nayak's user avatar
-1 votes
1 answer
33 views

AMQP Inserting Message into Rabbit MQ

I am trying to insert message into Rabbit MQ with host, port, user, pass, exchange Queue, Queue Name and Routing Key enter image description here getting these errors- ForgivingExceptionHandler: An ...
Saurabh's user avatar
0 votes
0 answers
33 views

/usr/bin/ld: cannot find -lamqpcpp [duplicate]

I'm trying to install amqpcpp a rabbitmq client for c++ as part of the steps for building my c++ application. I cloned the repo and put the folder in the projects directory. The dockerfile I'm using ...
Sijibomi's user avatar
0 votes
0 answers
131 views

TLS server: In state connection received CLIENT ALERT: Fatal - Unknown CA

I did enable TLS on my local, below are the setting in the rabbitMQ.config file. log.console = true log.console.level = debug log.file.level = debug listeners.tcp = none listeners.ssl.default = 5671 ...
user2467944's user avatar
0 votes
1 answer
46 views

MessageGroups and Exclusive Consumer using AMQPNetLite.Core 2.4.6

I'm attempting to the message grouping and exclusive queues features from ActiveMQ Artemis 2.30.0 using the .NET Core AMQP NuGet package, AMQPNetLite.Core. However, the documentation for AMQPNetLite ...
shyamasundara's user avatar
0 votes
0 answers
82 views

RabbitMQ - Queue does not get any messages after being idle for long time [ver 3.8.9]

When publishing a new message, the existing queues does not get any messages after being idle for long time. The producers publish message to the exchange successfully, but no traffic is seen on the ...
Kunjan Thadani's user avatar
0 votes
1 answer
199 views

Cannot connect to ActiveMQ Artemis with AMQP 0.9.1 client

I am trying to connect to an ActiveMQ Artemis broker with an AMQP 0.9.1 Go client, but there are some problems I can't figure out. This is my client code: package main import ( "fmt" ...
user6244's user avatar
2 votes
1 answer
29 views

amqp-cpp library: channel->cancel(consumerTag) doesn't seem to cancel

I'm using the AMQP-CPP library (not the amqp C library) to connect to RabbitMQ. Consuming a queue works, as does publishing. I don't use exchanges or anything, just one consumer on one queue. When ...
user22358964's user avatar
0 votes
1 answer
296 views

Facing connection reset by peer, errorContext[NAMESPACE: <Namespace>] while sending messages to Azure queue

I am trying to send a message to a queue on the Azure service bus with ClientSecretCredential.it is giving error while using AzureSDK code. The code and error trace are given below. The latest jars ...
user3725074's user avatar
1 vote
1 answer
74 views

how can I generate message queue and binding keys dynamically with PK value in SpringBoot AMQP

I want to implement a feature where users belonging to a specific group can post something within the group, and all members of the group will receive notifications. To achieve this, I studied AMQP ...
Owen Choi's user avatar
0 votes
0 answers
29 views

Trouble using cppyy to run c++ code that connects to a RabbitMQ instance with SSL connection

I am having trouble using cppyy to execute some c++ code which tries to connect to a RabbitMQ instance with SSL. The code to start the SSL connection is very similar to the amqp_ssl_connect.c example ...
sohmahmood's user avatar
0 votes
0 answers
76 views

How to see Unacknowledged messages from RabbitMQ with KEDA?

I have created a ScaledObject that scales Celery worker pods based on how many requests are present in a RabbitMQ queue. This is in an Azure Kubernetes Service cluster. I used the the following url ...
Jens Voorpyl's user avatar
0 votes
0 answers
34 views

RabbitMQ in local machine: service rabbitmq-server restart

I have a production RabbitMQ system on a server on cloud and there is a Nodejs application which is using this RabbitMQ server. The problem is the Nodejs application which is running on the cloud is ...
Abdol Seed's user avatar
  • 1,267
3 votes
1 answer
340 views

Mocking amqp091-go difficulties with interfaces

I'm trying to write unit tests for a pared down and slightly modified version of the Go AMQP consumer https://github.com/rabbitmq/amqp091-go/blob/main/_examples/consumer/consumer.go for a simple ...
Khorkrak's user avatar
  • 3,931
0 votes
1 answer
418 views

ActiveMQ Artemis does not respect broker.xml settings for queue deletion and queue configuration

I'm running ActiveMQ Artemis 2.28.0 with a broker config as shown below. I left the things in which I think are relevant (mainly default settings). I am sure the file is actually used because if I ...
Michiel's user avatar
0 votes
0 answers
111 views

Can you have one consumer listen to multiple queues using AMQP/RabbitMq?

I currently have a pool of machines that produce widgets, and I am using RabbitMQ to route jobs to each machine based on a routing key using a topic exchange. For example, I can produce a message onto ...
Simon Bowen's user avatar
0 votes
0 answers
35 views

Does CloudAMQP have dual support for AMPQ 1.0 and 0.9.1

On CloudAMQP there are logs which are telling that AMQP 1.0 is not supported and that it requires enabling the rabbitmq_amqp1_0 plugin =ERROR EVENT==== Wed, 07 Jun 2023 10:37:59 GMT === 2023-06-07 10:...
Stevan Tosic's user avatar
  • 6,759
0 votes
1 answer
785 views

AMQPConnectionClosedException: Broken pipe or closed connection

I wrote a microservice application in PHP, where microservices communicate with each other using queues in RabbitMQ (each microservice has its own queue). There was a problem: if you send more than ...
Jack Milean's user avatar
1 vote
1 answer
274 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
19 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
1 answer
143 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,775
0 votes
0 answers
35 views

Spring AMQP with R2DBC

I'm using Spring R2DBC and Spring AMQP (RabbitMQ). I'm trying to call some Mono @Transactionnal methods that modify the database when receiving a message from RabbitMQ but it seems that I'm not in ...
kevin guirado's user avatar
0 votes
2 answers
422 views

ActiveMQ Transport Protocol: amqps vs ampq+ssl

I try to consume messages from an ActiveMQ server via amqp protocol. Since there is a lot going on with ActiveMQ and the switch from javax.jms to jakarta.jms and the detach from the Spring-Boot v3 ...
fx88's user avatar
  • 43
0 votes
0 answers
42 views

Symfony AMQP retry on success...?

I currently have a communication between a site and an API, when I make a request to this API, AMQP launches a request and receives a response, however, it retries the request 3 times after getting a ...
Alex13's user avatar
  • 1
0 votes
1 answer
336 views

dead letter queue not getting message after retry completed

After retry limit reached message is not pushed to DLQ. Also my message in main queue is also removed getting empty logs after retry done. But retry is happening for the specified limit. After retry ...
Prithivi Thiyagu's user avatar
0 votes
0 answers
161 views

Strategy used by rabbitmq to store messages in RAM/Disk

I am using RabbitMQ version 3.7.17 and Classic Queues Version 1 (CDv1). Publishing message type is set to "persistent". According to RabbitMQ official documentation, in CQv1 (which is ...
Krishna Bagaria's user avatar
0 votes
1 answer
54 views

Amqprpc alpakka producer not receiving a response back

I´m currently trying to implement alpakka amqp queues, and specifically I´m trying to use rabbitmq as an RPC mechanism. So what I´m trying to do is to send messages from amqprpc flow, and then the ...
firas_frikha's user avatar
0 votes
0 answers
135 views

Why is my AmqpRejectAndDontRequeueException not being respected?

I have a spring boot service method as shown below. This receives a rabbit message and does some things. The problem is its attempting to consume the same message over and over again even if it throws ...
Harsha Limaye's user avatar
0 votes
1 answer
133 views

How to send video in the rabbitmq cloud with nodejs

So I tried sending normal text messages, they work fine, but when I try to send a video to the rabbitmq cloud, it successfully created the new queue but the queue shows empty:- import {Router} from '...
Aviato's user avatar
  • 85
0 votes
1 answer
177 views

Rabbit Mq Not Consuming Messages after first message

After posting message in queue, receiveing same message twice at the lisitener side. After receving the first message listner stops consuming furthe message . After i restart the listener application ...
Prithivi Thiyagu's user avatar
0 votes
1 answer
133 views

Performance problem sending big messages to qpid C++ broker using AMQP 1.0

I'm creating a proof of concept implementation in which I need to send files (sometimes large ones, up to 400Mb) embedded in messages using AMQP 1.0. I decided to use Apache's qpid proton client lib ...
Gabriel T's user avatar
0 votes
0 answers
24 views

AmqpAdmin.deleteQueue() reasserts?

I'm using AmqpAdmin.deleteQueue(queueName) in my application. Oddly, however, when this code runs,it causes the queues (which were earlier unbound from their exchanges) to not only not be deleted, but ...
Steve King's user avatar
0 votes
1 answer
306 views

What is the right way to publish message to RabbitMq with AMQP-CPP?

I want to use RabbitMq in my c++ program. I desided to use AMQP-CPP for this. When I used class MyConnectionHandler : public AMQP::ConnectionHandler from README file my messages weren't sent. Here is ...
Deadpool's user avatar
0 votes
2 answers
24 views

Is listening to an empty rmq queue network intensive?

In a microservice system I have two services: service1 which has a piece of data and service2 which needs that up to date data from time to time. In order to get the status, service2 calls service 1 ...
meJustAndrew's user avatar
  • 6,131
0 votes
1 answer
111 views

AMQP Qpid ActiveMQ routing key

I'm using ActiveMQ "Classic," and I want to use AMQP protocol. For the moment I am trying to use AMQP 1.0 and the Java client Qpid JMS client 2.2.0 and qpid-amqp-1-0-client-jms 0.32 with ...
Mançaux Pierre-Alexandre's user avatar

1
2 3 4 5
51