Resultados de la búsqueda a petición "rabbitmq"
Prueba de método @RabbitListener en la aplicación SpringBoot
Código: RabbitMQListener: @Component public class ServerThroughRabbitMQ implements ServerThroughAMQPBroker { private static final AtomicLong ID_COUNTER=new AtomicLong(); private final long instanceId=ID_COUNTER.incrementAndGet(); @Autowired ...
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 ...
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 ...
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 ...
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() ...
Cómo implementar el mecanismo RPC usando RabbitMQ en Java
¿Cómo implementar el Mecanismo RPC (productor y consumidor) usando RabbitMQ en Java? También estoy visitando el sitio oficial http://www.rabbitmq.com/api-guide.html#rpc [http://www.rabbitmq.com/api-guide.html#rpc]pero estoy recibiendo ...
Cómo pedirle a RabbitMQ que vuelva a intentar cuando ocurra una Excepción comercial en el caso de uso de Spring Asynchronous MessageListener
Tengo un escucha de mensajes Spring AMQP ejecutándose. public class ConsumerService implements MessageListener { @Autowired RabbitTemplate rabbitTemplate; @Override public void onMessage(Message message) { try { testService.process(message); ...
¿Cómo compila una extensión PHP en Windows con cygwin / mingw?
Estoy tratando de construir elRabbitMQ PHP wrapper [http://code.google.com/p/php-rabbit/]y elContenedor PHP AMPQ [http://code.google.com/p/php-amqp/]en Windows (64) usando Cygwin. He compilado con éxito la biblioteca C subyacente ...
SparkStreaming, RabbitMQ y MQTT en python usando pika
Solo para complicar las cosas, me gustaría consumir mensajes de la cola rabbitMQ. Ahora sé que hay un complemento para MQTT en conejo ( https://www.rabbitmq.com/mqtt.html [https://www.rabbitmq.com/mqtt.html]) Sin embargo, parece que no puedo ...
¿Cómo RabbitMQ realmente almacena el mensaje físicamente?
Quiero saber cómo RabbitMQ almacena los mensajes físicamente en su RAM y disco. Sé que RabbitMQ intenta mantener los mensajes en la memoria (pero no sé cómo se colocan los mensajes en la RAM). Pero los mensajes se pueden verter en el ...