Resultados da pesquisa a pedido "message-queue"

3 a resposta

Entendendo a ligação java zeromq

2 a resposta

Por que precisamos de corretores de mensagens como o RabbitMQ em um banco de dados como o PostgreSQL?

2 a resposta

Diferença na Fila de Mensagens vs Fila de Tarefas

Eu me pergunto qual é a diferença entre eles. Eles estão descrevendo a mesma coisa?O serviço do Google App EngineFila de Tarefas é uma implementação do Messa...

8 a resposta

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 ...

10 a resposta

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 ...

6 a resposta

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 ...

2 a resposta

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 ...

2 a resposta

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 { ...

8 a resposta

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 ...

1 a resposta

riando filas dinamicamente com o aipo

Estou escrevendo um gerenciador de listas de discussão usando Django, Aipo e RabbitMQ. Quando uma mensagem chega, uma tarefa é executada para cada destinatário. Todas as tarefas vão para uma única fila e um ou mais funcionários consomem tarefas ...