Questions tagged [rabbitmq]
RabbitMQ is an open-source message broker originally implementing the AMQP protocol with additional messaging protocols supported via a plug-in architecture. This tag should be used with questions involving the RabbitMQ server message broker product or questions concerning the source code and implementation of the RabbitMQ product. A specific protocol tag such as amqp or mqtt may also be appropriate as well as the OS and programming language being used.
rabbitmq
14,466
questions
0
votes
0
answers
17
views
spring-cloud-contract and spring-boot-starter-amqp (Rabbit), problem with producer: NoSuchBeanDefinitionException: No bean named available
I'm having trouble implementing Spring Cloud Contract on the producer side to generate contracts for event triggering via RabbitMQ. I`m using spring-boot-starter-amqp as interface to RabbitMq.
The ...
0
votes
0
answers
6
views
Access env object inside config file in Strapi
In strapi, how can I retrieve the env variables from a config file. I have two config files: one to handle rabbitmq connection rabbitmq, and one to handle the topics and sending of message topics.ts. ...
- 363
0
votes
1
answer
10
views
How to configure MassTransit to get messages from Azure Event Hub, store fault and/or error message in RabbitMQ and correctly consume Fault<T>
I'm a newbie to MassTransit and for now I correctly configure MassTransit to get and consume messages of type "T" from Azure Event Hub, but a cannot view/consume Fault<T> messages when ...
0
votes
0
answers
19
views
RabbitMQ stream by request and response pattern
I was playing with RabbitMq streams using .net, so idea is that I have a producer that sends requests and expects chunked resposne from consumer. Consumer consumes request and prepares answer, so what ...
0
votes
0
answers
17
views
Celery returns wrong info about current tasks in one worker
I have a bundle which contains Celery and RabbitMQ for tasks and FastApi app for web requests.
The celery app starts from command prompt with celery -A celery_app worker -l info -P gevent.
Rabbit is ...
- 139
0
votes
0
answers
6
views
Rabbitmq starts on boot after few mins it exited
rabbitmq server starts on boot but after 1 min it gets stopped due to below error. I am using rabbitmq-server (3.12.12). if again i restart the rabbitmq service is working here
2024-07-23 20:06:09....
- 53
0
votes
0
answers
12
views
Routing celery task to a specific worker
I am designing a system where each user will have its own LLM. When a client logs into the system, an unused worker will load a model and answer all chat requests for the client during the session. ...
- 19
0
votes
0
answers
19
views
What would be a good way to establish communication between servers with a queue? [closed]
I'm looking for a decentralized way to exchange messages (JSON) between two linux servers. The difficult thing is making sure the messages arrive in case of an outage. Its crucial, that no message ...
-1
votes
0
answers
35
views
How to run bin/console command to the server? [closed]
I would like to ask your advice on how to run the command php bin/console app:rabbitmq-consumer messaging on our server.
I used cronjob to run it every minute but I'm not sure if that will be a good ...
- 43
0
votes
0
answers
20
views
How to add start time and end time in the streaming dataset script to get only a particular interval of data
import pika
import json
username='0ccb6575-a617-44b5-a58f-ba6a77d1e372'
apiKey='This is little bit confidential'
id='0ccb6575-a617-44b5-a58f-ba6a77d1e372/...
1
vote
1
answer
28
views
How do I implement x-consistent-hash-exchange using Spring XML
All other exchange types are declared in http://www.springframework.org/schema/rabbit schema, but couldn't find x-consistent-hash-exchange in it. Where is it defined?
I tried implementing consistent ...
- 13
0
votes
0
answers
45
views
RabbitMQ: Reading single message from queue based on correlation id using java
Looking for solution to read single message from queue where each message is stored with correlationId.
Code snippet to publish message with correlation id into queue.
public static void ...
2
votes
0
answers
31
views
Rabbitmq Configuration
I have deleted and recreated the rabbitmq queue with the version 2 properties But I am getting this error
12:57:55.286 [AMQP Connection 127.0.0.1:5672] ERROR o.s.a.r.c.CachingConnectionFactory - ...
- 21
1
vote
0
answers
17
views
How to connect main app with microservice rabbitMQ to use websockets from microservice
I have main app with connected webSockets, but also, I have RabbitMQ microservice with methods where I want to send message to client by websockets. Could you assist with connection?
Here is my app....
- 11
0
votes
2
answers
15
views
Celery with RabbitMQ and Eventlet Not Working with Boto3 Client & Timestream
I am trying to use Celery with RabbitMQ and Eventlet to handle asynchronous tasks in my Python application. One of my tasks involves uploading files to an S3 bucket using the Boto3 client. However, I ...
- 3,275