Resultados da pesquisa a pedido "message-queue"
omparação de desempenho entre ZeroMQ, RabbitMQ e Apache Qpid
Preciso de um barramento de mensagens de alto desempenho para meu aplicativo, por isso estou avaliando o desempenho deZeroMQ, RabbitMQ eApache Qpid. Para medir o desempenho, estou executando um programa de teste que publica, por exemplo, 10.000 ...
MSMQ receber com transação - a reversão não torna a mensagem disponível novamente
Eu tenho isso em uma classe chamada "MessageQueueReceive" public MessageQueueTransaction BlockingReceive(out Message message) { MessageQueueTransaction tran = null; message = null; tran = new MessageQueueTransaction(); tran.Begin(); try { ...
quando um canal AMQP / RabbitMQ sem conexão morre?
Eu tenho um simples programa de teste RabbitMQ enfileirando mensagens aleatoriamente e outro lendo-as, todas usando Spring-AMQP. Se o consumidor morrer (por exemplo, encerrar um processo sem ter a chance de fechar sua conexão ou canal), todas as ...
Bloqueios e mensagens de busca em lote com RabbitMq
Estou tentando usar o RabbitMq de uma maneira não convencional (embora neste momento eu possa escolher qualquer outra implementação de fila de mensagens, se necessário). Em vez de deixar as mensagens push do Rabbit para meus consumidores, o ...
Erro "etiqueta de entrega desconhecida" ocorre quando tento ack mensagens para RabbitMQ usando pika (python)
Quero processar mensagens em alguns threads, mas estou recebendo erro durante a execução deste código: from __future__ import with_statement import pika import sys from pika.adapters.blocking_connection import BlockingConnection from pika ...
s filas de mensagens estão obsoletas no linu
Eu tenho jogado com filas de mensagens (System V, mas POSIX também deve estar bem) no Linux recentemente e elas parecem perfeitas para o meu aplicativo, mas depois de ler The Art of Unix Programming, não tenho certeza se elas são realmente boas. ...
posix pipe como uma fila de trabalho
s implementações normais de uma fila de trabalho que vi envolvem mutexes e variáveis de condiçã ConsumidorA) Acquires Lock B) While Queue empty Wait on Condition Variable (thus suspending thread and releasing lock) C) Work object retrieved from ...