Category "rabbitmq"

Spring AMQP - RabbitMQ connection is not created on application startup

I have a Spring Boot application and my goal is to declare queues, exchanges, and bindings on application startup. The application will produce messages to vari

Problems with RabbitMQ and NestJS. I can't publish a message with nestjs-rabbitmq and NestJS

I have NestJS 8.0.0 and I'm using @golevelup/nestjs-rabbitmq": "2.2.0. Basically I have handling messages working fine but I can't send any, I just get a "Canno

NestJS microservices error with "No matching message handler"

I'm building an application with microservices communicating through RabbitMQ (request-response pattern). Everything works fine but still I have a problem with

How to propagate context between two services communicating via rabbitmq in opentelemetry?

I am trying to find a way to propagate context between two services communicating via rabbitmq in opentelemetry. There was an article for doing similar in Go ar

Systemd consumer service starts before broker (RabbitMQ )

I have a RabbitMQ server set up on my raspberry Pi and I want the same device to run a consumer to handle messages to one of my queues. I first tried executing

Can I send/receive Java objects to RabbitMQ using Java built-in IO classes instead of Spring AMQP?

I need to send/receive Java POJOs to/from RabbitMQ. There is a ready solution with Spring AMQP, but I've managed to do it with built-in java.io.* (serialize POJ

How to extract data using JMeter and AMQP Consumer?

i am using plugin JMeter-Rabbit-AMQP. I don't understand how to extract data from consumer. I publish, and a response is returned to another queue that my consu

Can we connect RabbitMq directly from Angular Application

In my current Angular project , have requirement to connect RabbitMq server queue. I have tried amqp, amqp-ts npm librarires but those are node applications. ca

Callback or event/delegate from C# core rest api BackgroundService

I´m currently working on a C# core 5.0 REST API with a RabbitMQ messagebus. I´ve created a class that derives from BackgroundService and the consume

Openstack install fail on RabbitMQ - Centos8

I am following this post to install Packstack on my Centos8 server. Everything goes fine until I reach this install step - "packstack --answer-file /root/openst

RabbitMQ doesn't show me the queues and exchange created in my Spring consumer and publisher apps

I am trying to create a publisher and consumer apps in spring using RabbitMQ. Every thing works fine and when the publisher sends a message, the consumer receiv

RabbitMQ doesn't show me the queues and exchange created in my Spring consumer and publisher apps

I am trying to create a publisher and consumer apps in spring using RabbitMQ. Every thing works fine and when the publisher sends a message, the consumer receiv

Unable to install rabbitmq due to incorrect versions of erlang dependencies

I have erlang 21.3 installed: $ erl -eval 'erlang:display(erlang:system_info(otp_release)), halt().' -noshell "21" But the rabbitmq installer does not think

AMQP Closing all channels from connection when docker run on port 5672

I have run Rabbitmq as a docker compose and it work well with port 15672 on browser, but 5672 not working. docker-compose rabbitmq: image: 'rabbitmq:3-manag

Symfony 3.4 and MySQl 8. General error: 2006 MySQL server has gone away when running a transaction in a rabbitmq queue

I have one system (Symfony 5, symfony/messenger) sending data to another (Symfony 3.4, enqueue/enqueue-bundle 0.9) using a rabbitmq queue. The data is used to c

How to close connections in celery to avoid 'client unexpectedly closed TCP connection' warnings in RabbitMQ

When running the following simple celery task I always get 'client unexpectedly closed TCP connection' warnings in the RabbitMQ log output. from celery import

Continuously hitting the GitHub secondary rate limit even after following the best practices?

In my application I am making authenticated requests to the GitHub search API with a token. I am making a request every 2s to stay within the primary rate limit

How To apply Sync police On Rabbit MQ

how to apply Sync Policy on Rabbit mQ . how to apply Sync Policy on Rabbit mQ .how to apply Sync Policy on Rabbit mQ

Apache Flume stuck after ChannelFullException is occured 500 times

I have flume configuration with rabbitmq source, file channel and solr sink. Sometimes sink becomes so busy and file channel is filling up. At that time Channel

Sending messages to durable queue using Rabbit perf test tool

How can I send messages to a durable queue using the Rabbit Perf Test tool? I am getting this following error: Caused by: com.rabbitmq.client.ShutdownSignalExc