Estoy trabajando en una aplicación basada en microservicios. Está compuesta por alrededor de 30 microservicios y algunos de ellos se comunican entre sí a través de RabbitMQ. Estos servicios tienen nombres de exchanges, colas y claves de enrutamiento en su archivo de configuración (application.yml). Todos los beans correspondientes (incluyendo los . . . Read more
Estoy utilizando RabbitMQ como una cola de diferentes mensajes. Cuando consumo estos mensajes con dos consumidores distintos de una cola, los proceso e inserto los resultados de procesamiento en una base de datos: def consumer_callback(self, channel, delivery_tag, properties, message): result = hacer_algun_procesamiento(mensaje) insertar_en_db(resultado) channel.basic_ack(delivery_tag) Quiero consumir mensajes en masa desde . . . Read more
Me encontré con un problema después de la instalación de Rabbit MQ donde todo se configuró con las aplicaciones web en la máquina y se comunicaba con aplicaciones locales. Sin embargo, la máquina tuvo que ser movida a una traba diferente de máquinas y renombrada como resultado. Ahora, Rabbit MQ . . . Read more