Category "rabbitmq"

Shovel Configuration between 2 AWS MQ private RabbitMQ clusters

So I have 2 AWS MQ RabbitMQ clusters in the same vpc without public accessibility. Both are multi az Clusters with 3 nodes. Lets say rabbitmq-1 rabbitmq-2 Now I

Shovel Configuration between 2 AWS MQ private RabbitMQ clusters

So I have 2 AWS MQ RabbitMQ clusters in the same vpc without public accessibility. Both are multi az Clusters with 3 nodes. Lets say rabbitmq-1 rabbitmq-2 Now I

RabbitMQ not working when services are dockerized

So I have 2 services. Kweet (which is a tweet) and User. When I run the 2 services manually + rest of the services in docker, it works. Rest of services include

Uncomitted Messages with Rebus ESB

Our organization is running a .net application using rebus esb for executing business workflows. The system is processing a lot of messages with a number of han

Docker rabbitmq doesn't work with RABBITMQ_DEFAULT_USER and RABBITMQ_DEFAULT_PASS

I'm trying to run rabbitmq service with following configuration: version: '3.9' services: rabbit-mq: container_name: rabbitmq image: rabbitmq:3-manage

How to Kill all Celery background proces

Killing all celery processes involves 'grep'ing on 'ps' command and run kill command on all PID. Greping on ps command results in showing up self process info o

Celery with Server MongoDB

Working on getting Celery setup with a mongodb as result_backend. Following the configuration guidelines set out in the official docs, my celeryconfig.py is set

Why is JobConsumer not being hit/run?

I am trying out the new MassTransit IJobConsumer implementation, and although I've tried to follow the documentation, the JobConsumer I have written is never be

Dramatiq worker getting killed every often

I have started a dramatiq worker to do some task and after a point, it is just stuck and throws this below-mentioned error after some time. [MainThread] [dramat

RabbitMQ ignore config "heartbeat" rule

RabbitMQ 3.10.1 rabbitmq-diagnostics status ... Config files * /etc/rabbitmq/rabbitmq.config ... rabbitmq.config: [ {rabbit, [ {heartbeat, 90}

rabbitMQ sender with node-red

I am trying to connect node-red with rabbitMQ. The program will recive a text with the diet that the AI chose for each day. I made the rabbitMQ Configure java f

MySQL Database Manager with RabbitMQ

I'm new to message brokers like RabbitMQ and I have to develop an application with RabbitMQ that interfaces with MySQL, so the final task is to create a MySQL D

How to know list of servers that is consuming queue in rabbitmq?

I checked the connections tab and I cannot see the queues consumed by the servers. I also checked the queues tab and I cannot see the servers consuming the queu

RabbitMQ - Diff between 'delivery-limit' and 'x-delivery-limit' queue arguments

What is the difference between delivery-limit and x-delivery-limit? When I set the x-delivery-limit as RabbitMQ queue argument I can see it is limiting my messa

Can you import a NestJS module on condition

I'am creating a microservice in NestJS. Now I want to use RabbitMQ to send messages to another service. My question is: is it possible to import the RabbitmqMod

Can you import a NestJS module on condition

I'am creating a microservice in NestJS. Now I want to use RabbitMQ to send messages to another service. My question is: is it possible to import the RabbitmqMod

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