Preguntas etiquetadas [rabbitmq]

0 votos
0 respuestas
No se puede transmitir el mensaje utilizando apio
Estoy tratando de usar la compilación de apio para el enrutamiento de difusión utilizando Difusión y utilizando rabbitmq como intermediario. He...
preguntó hace 1 mes
1 votos
0 respuestas
RabbitMQ - ¿Existe un sistema de prueba de ack para hacer frente a una nueva entrega?
En RabbitMQ, cuando se configura con acks habilitados ... Si un consumidor falla su latido cardíaco y el conejo vuelve a poner en cola una pi...
preguntó hace 1 mes
0 votos
1 respuestas
Cómo leer los mensajes de cola de RabbitMQ uno por uno
Tengo un requisito donde necesito leer los mensajes de DLQ y realizar una acción apropiada en base a eso. Anteriormente, el siguiente fragmento...
preguntó hace 1 mes
-2 votos
0 respuestas
cómo enviar y manejar mensajes en 2 aplicaciones de symfony deiffrent [cerrado]
¿Es posible enviar y recibir en 2 aplicaciones Symfony diferentes de rabbitmq!? por ejemplo, la aplicación 1 envía un mensaje y la aplicación 2...
preguntó hace 1 mes
0 votos
1 respuestas
El consumidor de RabbitMQ en la aplicación ASP.NET Core con la solicitud web
El resumen que hago se resuelve en Setup RabbitMQ consumidor en la aplicación ASP.NET Core pero mi consumidor de Rabbit en línea si hago una s...
preguntó hace 1 mes
0 votos
0 respuestas
¿Por qué mi mensaje RabbitMQ es imposible de serializar utilizando Apache Beam?
Estoy intentando leer una cola de RabbitMQ usando Apache Beam. He escrito algún código de transformación para tener mensajes escritos a Kafka. I...
preguntó hace 2 meses
0 votos
2 respuestas
Massemploy / RabbitMQ: ¿por qué se omiten tantos mensajes?
Estoy trabajando con 2 aplicaciones de consola .NET Core en un escenario de productor /consumidor con Massemploy /RabbitMQ. Necesito asegurarme...
preguntó hace 1 mes
0 votos
0 respuestas
apio: ¿por qué es útil cuando elimino el elemento "search localdomain" en /etc/resolv.conf?
cuando uso "celery -A task worker -l info", se produce el siguiente nodo de trabajo : [2019-04-26 20:27:00,290: ERROR/MainProcess] consumer:...
preguntó hace 2 meses
0 votos
1 respuestas
Recibe mensajes por propiedad o encabezado en RabbitMQ
Soy nuevo en RabbitMQ y he enfrentado un problema. Estoy tratando de obtener mensajes de la cola por el método API. Ya lo he hecho. Quiero obten...
preguntó hace 2 meses
0 votos
1 respuestas
Procesamiento resistente de mensajes de RabbitMQ
No estoy seguro de cómo manejar los mensajes de RabbitMQ de forma flexible en caso de una interrupción intermitente. Me suscribo en un servic...
preguntó hace 2 meses
0 votos
1 respuestas
RabbitMQ Múltiples consumidores únicos en el servicio de Windows
He buscado en StackOverflow y no creo que los otros problemas relacionados con varios consumidores coincidan con lo que estoy intentando. Ten...
preguntó hace 2 meses
0 votos
0 respuestas
Agregar colas a Rabbitmq y trabajadores a las colas en Celery
Intentando ejecutar aproximadamente 66 scripts de Python que realizan algunas tareas de manipulación de datos. Tres scripts tardan mucho tiempo...
preguntó hace 2 meses
1 votos
0 respuestas
¿Cómo acceder a los valores de una lista que está dentro de tasks.py a través de views.py mientras la lista se está llenando y la tarea aún no está terminada?
Tengo una función simple en views.py y necesito llamar a una tarea en esta función para hacer algo y poner el resultado en una lista. Por lo t...
0 votos
2 respuestas
Cómo utilizar el intercambio de encabezados para enviar y recibir objetos java como mensajes de colas en rabbitmq
Estoy tratando de usar el intercambio de encabezados en rabbitmq para producir y consumir mensajes. Cuando intento generar el mensaje, debo conv...
preguntó hace 2 meses
1 votos
1 respuestas
Coherencia de datos entre microservicios con RabbitMq
Estoy intentando configurar una demostración práctica de Microservice para algunos sistemas internos simples que se ocupan de la gestión de pedi...
preguntó hace 2 meses
0 votos
0 respuestas
error de Python 104 Restablecimiento de la conexión por pares utilizando rabbitmq SSL
Estoy intentando configurar SSL en la conexión entre rabbitmq y el cliente Pika (en python 2.7), por lo tanto, he seguido el tutorial en https:...
preguntó hace 2 meses
0 votos
1 respuestas
Cómo dejar de consumir mensajes con gracia con @RabbitListener
¿Hay una manera de detener con gracia un ListenerContainer, y su asociado Consumers. Lo que estoy tratando de lograr. Deja de consumir...
2 votos
2 respuestas
¿Cómo consumir 100 mensajes sin un acuse de recibo, luego funcionan y luego los reconocen?
Estoy consumiendo mensajes de un rabbitmq con spring amqp. Estoy consumiendo un mensaje a la vez y es bastante lento porque lo guardo en DB. Así...
preguntó hace 2 meses
0 votos
0 respuestas
Reenvío de mensajes no confirmados al mismo consumidor sin cerrar el canal o el reinicio del agente
Considere el siguiente escenario: Un mensaje se pone en una cola. Se declara que la cola es duradera. Un solo consumidor recibe el mens...
preguntó hace 2 meses
0 votos
1 respuestas
No se pudo conectar a RabbitMQ iniciado con Docker en un programa de C # (con RabbitMQ.Client)
Comencé un contenedor RabbitMQ siguiendo el artículo: https://docs.docker.com/samples /library /rabbitmq utilizando la imagen, incluida la her...
preguntó hace 2 meses
1 votos
0 respuestas
CQRS y guía de fuentes de eventos
Quiero crear una arquitectura CQRS y fuente de eventos que sea muy barata, muy flexible y sin complicaciones. Quiero asegurarme de que los...
preguntó hace 2 meses
3 votos
3 respuestas
Fallas de mensajes de ParseFrom en java desde C ++
Tengo una pregunta /problema. Estoy enviando mensajes desde C ++ a Java (Play framework) usando RabbitMq. Por lo tanto, en el lado C ++ usé l...
preguntó hace 2 meses
0 votos
0 respuestas
¿Cómo interactuar con la versión estándar del depurador de Visual Studio al depurar una aplicación de compilación de .NET docker?
Tengo un proyecto de consola .NET C # simple que consume RabbitMQ con Mass transit: using System; using MassTransit; namespace ConsoleApp1 {...
preguntó hace 1 mes
0 votos
0 respuestas
La formación de clústeres en una sola máquina, iniciando el segundo nodo se bloquea porque el puerto está en uso
En mi escritorio, estoy tratando de crear un clúster RabbitMQ. Después de instalar el servidor RabbitMQ v3.7.14 (y Erlang v21.3), el primer nodo...
preguntó hace 1 mes
0 votos
0 respuestas
Hacer que Locust espere entre ejecuciones de tareas
Estoy usando Locust para insertar mensajes en una cola RabbitMQ. Puedo hacer esto fácilmente usando el ejemplo de RabbitMQ de locust.io-demo r...
preguntó hace 2 meses