Category "rabbitmq"

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

AMQP - Argo-events: argo-workflow not triggered

I am trying to run an argo-workflow triggered by event-source that listens to messages published on RabbitMQ. I followed the exact steps in here: AMQP-Argo Eve

Cannot connect to RabbitMQ Celery

I am using Celery,RabbitMq,FastAPI,docker to develop a application.This is my docker-compose-yml. services: rabbitmq: container_name: rabbitmq

Install reportportal on kube get error : starting Tomcat context. Exception: org...message: Error creating bean with name 'servletEndpointRegistrar'

I've installed reportportal 5.7.0 to kubernetes cluster. I've implemented it from doc:https://github.com/reportportal/kubernetes/tree/develop/reportportal. From

How to connect to rabbit on vagrant host?

I set up a server using vagrant on a virtual machine. After installing rabbitmq, I tried to connect to it using script outside VM. There's already Django and Ra

RabbitMQ Clustering with 1Master & 5Nodes

Recently i deployed and implement RabbitMQ with 1Master and 2Nodes (as slaves). Is it possible to clustering RabbitMQ with 1Master and 5Nodes? For the record in

Spring Cloud Stream RabbitMQ wait for publisher confirms

I am using Spring Cloud Stream with the RabbitMQ binder. I use the StreamBridge to send messages to a destination. I want to send a message with StreamBridge an

RabbitMQ PRECONDITION_FAILED - unknown delivery tag

We have a PHP app that forwards messages from RabbitMQ to connected devices down a WebSocket connection (PHP AMQP pecl extension v1.7.1 & RabbitMQ 3.6.6).

How to solve the data loss issue in Event Emitters in NodeJS? MicroServices

Below code is just for testing purpose , if it works then i want to implement the same in real project with microservices. I have 4 microservices in one server.

How do I deserialize a dead lettered message when dead lettering changes the type?

I'm trying to write a dead letter handler service that reads messages off of a dead letter queue and then does something with the message based on the type, con

What are the differences between gRPC AsyncIO and RabbitMQ and when to use them?

I want to implement event-driven communication in my microservices architecture. For example, if event A happens, services X and Y would carry out certain thing

How to keep forked child process alive in node js

I want to create a rabbitmq cli running like foreverjs with node. It can spawn child_process and keep it running in the background and can communicate with chil

Google Pub Sub/Lite vs RabbitMQ

I would like to confront my understanding of google pubSub/lite vs RabbitMQ (using MQTT over WSS). My use case is that I need something like a topic exchange. T