Entendiendo el enlace java zeromq

Estoy investigando zeromq como una solución de paso de mensajes en un proyecto java, pero las instrucciones sobre el enlace de java me resultan un poco difíc...

¿Por qué necesitamos agentes de mensajes como RabbitMQ sobre una base de datos como PostgreSQL?

Diferencia entre la cola de mensajes y la cola de tareas

posix pipe como cola de trabajo

as implementaciones normales de una cola de trabajo que he visto involucran mutexes y variables de condición. ConsumidorA) Acquires Lock B) While Queue empty Wait on Condition Variable (thus suspending thread and releasing lock) C) Work object ...

Error "etiqueta de entrega desconocida" se produce cuando intento enviar mensajes a RabbitMQ usando pika (python)

Quiero procesar mensajes en algunos hilos pero recibo un error durante la ejecución de este código: from __future__ import with_statement import pika import sys from pika.adapters.blocking_connection import BlockingConnection from pika ...

Locks y mensajes de recuperación por lotes con RabbitMq

Estoy tratando de usar RabbitMq de una manera menos convencional (aunque en este momento puedo elegir cualquier otra implementación de la cola de mensajes si es necesario). En lugar de dejar mensajes de inserción de Rabbit a mis consumidores, el ...

¿Cuándo muere un canal AMQP / RabbitMQ sin conexiones?

Tengo un simple programa de prueba RabbitMQ que pone en cola mensajes al azar, y otro que los lee, todo usando Spring-AMQP. Si el consumidor muere (por ejemplo, eliminando un proceso sin tener la oportunidad de cerrar su conexión o canal), ...

MSMQ recibe con la transacción: la reversión no hace que el mensaje vuelva a estar disponible

Tengo esto en una clase llamada "MessageQueueReceive". public MessageQueueTransaction BlockingReceive(out Message message) { MessageQueueTransaction tran = null; message = null; tran = new MessageQueueTransaction(); tran.Begin(); try { message ...

Comparación de rendimiento entre ZeroMQ, RabbitMQ y Apache Qpid

Necesito un bus de mensajes de alto rendimiento para mi aplicación, así que estoy evaluando el rendimiento deZeroMQ, RabbitMQ yApache Qpid. Para medir el rendimiento, estoy ejecutando un programa de prueba que publica, digamos, 10,000 mensajes ...

Creando colas dinámicamente con Celery

Estoy escribiendo un administrador de listas de correo con Django, Celery y RabbitMQ. Cuando llega un mensaje, se ejecuta una tarea para cada destinatario. Todas las tareas van a una sola cola, y uno o más trabajadores consumen tareas de la cola, ...