Resultados de la búsqueda a petición "rabbitmq"
¿Cómo eliminar selectivamente mensajes de una cola AMQP (RabbitMQ)?
Me gustaría eliminar selectivamente los mensajes de una cola AMQP sin siquiera leerlos. El escenario es el siguiente: El lado emisor desea que caduquen los mensajes de tipo X basándose en el hecho de que llegó nueva información de tipo X. ...
RabbitMQ C # API Consumo de mensajes basado en eventos
while (true) { BasicDeliverEventArgs e = (BasicDeliverEventArgs)Consumer.Queue.Dequeue(); IBasicProperties properties = e.BasicProperties; byte[] body = e.Body; Console.WriteLine("Recieved Message : " + Encoding.UTF8.GetString(body)); ...
Cómo lograr concurrencia con un oyente de mensajes no seguro para subprocesos
La respuesta aesta pregunta [https://stackoverflow.com/questions/23341811/how-is-concurrency-in-spring-amqp-listener-container-implemented] explica cómo usar el alcance del prototipo con<rabbit:listener-container/> en Spring AMQP cuando el oyente ...
Apio: ¿cómo limitar el número de tareas en la cola y dejar de alimentar cuando está lleno?
Soy muy nuevo en Apio y aquí está la pregunta que tengo: Supongamos que tengo un script que se supone que constantemente obtiene nuevos datos de DB y los envía a los trabajadores que usan Celery. task.py # Celery Task from celery import Celery ...
Mensajes programados / retrasados en Spring AMQP RabbitMq
Estoy luchando por encontrar el camino para los mensajes programados / retrasados en Spring AMQP / Rabbit MQ. Después de mucho buscar todavía no puedo hacer eso en Spring AMQP. ¿Puede alguien decirme cómo hacerlo?x-delay en primavera AMQP. Quiero ...
Descomponer en una interfaz {} y luego realizar una aserción de tipo
Yo tengo unstring a través de un sistema de mensajes rabbitmq. Antes de enviar, yo suelojson.Marshal, convierte el resultado astring y enviar a través de rabbitmq. Las estructuras que convierto y envío pueden ser: (cambió los nombres y ...
Si se debe crear una conexión cada vez que amqp.Dial es seguro o no en go lang
Como se menciona en los documentos de RabbitMQ, las conexiones tcp son caras de hacer. Entonces, para ese concepto de canal se introdujo. Ahora me encontré con estoejemplo [https://www.rabbitmq.com/tutorials/tutorial-four-go.html]. En elmain() ...
Spark Streaming estructurado con fuente RabbitMQ
Estoy tratando de escribir un receptor personalizado paraStructured Streaming que consumirá mensajes deRabbitMQ. Spark lanzado recientemente [https://databricks.com/blog/2018/02/28/introducing-apache-spark-2-3.html] DataSource V2 API, que ...
¿Por qué necesitamos usar rabbitmq
¿Por qué necesitamos RabbitMQ cuando tenemos un marco de red más potente en Python llamado Twisted? Estoy tratando de entender la razón por la cual alguien querría usar RabbitMQ. ¿Podría proporcionar un escenario o un ejemplo usando ...
Pass la url en el método de análisis en scrapy que se consumió de RabbitMQ
Estoy usando el scrapy para consumir el mensaje (url) del RabbitMQ, pero cuando uso el rendimiento para llamar al método de análisis pasando mi url como parámetros. El programa no viene dentro del método de devolución de llamada. A continuación ...