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,469
questions
0
votes
0
answers
13
views
What would be a good way to establish communication between servers with a queue?
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
30
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
18
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
18
views
Rabbitmq: 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?
Tried implementing consistent ...
- 11
0
votes
0
answers
31
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
30
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
15
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
1
answer
12
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
0
votes
0
answers
27
views
Celery Task multiple submissions or duplications
I have a simple celery worker(redis and postgresql backend) that runs 3 periodic tasks [every 15 mins, every hour, every day].
For some reason that I haven't been able to deduce yet, my tasks are ...
0
votes
1
answer
18
views
Many SimpleMessageListenerContainers lead to "Consumer failed to start"
I use spring boot amqp and the x-consistent-hash RabbitMQ plugin. I need
multiple queues bound to the same x-consistent-hash exchange
separate listener for each queue to keep partial ordering
...
0
votes
2
answers
31
views
Flask + Celery + RabbitMQ - kombu.exceptions.operationalerror errno 111 connection refused
below the are code snippets for flask+celery+rabbitMQ,the issue is they are working in local ,but when I deployed on EC2 instance ,I am getting errno 111 connection refused .
start_celery.py
from ...
0
votes
0
answers
47
views
MassTransit Saga State Machine - Timeout caught while waiting for response from State Machine
In the Order service, after sending an event to the State Machine in the CreateOrderCommand Handle method in the OrderCommandHandler, the State Machine sends another event to the Payment Service. ...
- 15
0
votes
1
answer
27
views
spring boot app with rabbitmq queue connection refused while running by dockercompose
services:
postgres:
container_name: postgres
image: postgres:latest
environment:
POSTGRES_DB: mydatabase
POSTGRES_USER: myuser
POSTGRES_PASSWORD: mypassword
ports:
...
- 1
0
votes
0
answers
19
views
RabbitMQ vs Nats JS
I am new to RabbitMQ and wanted to know the difference between RabbitMQ and Nats JetStream. Most importantly, they both have something like two-level routing. I would like to understand in which cases ...
0
votes
1
answer
33
views
RabbitMQ Client .Net Core Timing Out under load after rabbitmq upgrade. Consumer System.TimeoutException
We have a system that was running RabbitMQ 3.8.5 with RabbitMQ.Client 5.2.0. Part of the way the system uses rabbit is by creating a consumer to wait for a specific command from a different executable ...
- 403