Resultados da pesquisa a pedido "rabbitmq"
Como consumir uma mensagem?
Comexemplo [http://www.rabbitmq.com/tutorials/tutorial-one-java.html]em rabbitmq, o consumidor recebe todas as mensagens da fila de uma vez. Como consumir uma mensagem e sair? QueueingConsumer consumer = new ...
Capture o Heroku SIGTERM em trabalhadores de aipo para encerrar o trabalhador graciosamente
Eu fiz uma tonelada de pesquisas sobre isso e estou surpreso por ainda não encontrar uma boa resposta para isso em nenhum lugar. Estou executando um aplicativo grande no Heroku e tenho certas tarefas de aipo que são executadas por um ...
Como fazer um simples Pika SelectConnection para enviar uma mensagem, em python?
Estou tentando converter meu código para enviar mensagens rabbitmq via Pika. Estou com muitos problemas para entender como enviar uma mensagem simples usando uma conexão assíncrona (como SelectConnection). No meu código antigo, que uso a ...
Como usar a fila de mensagens pela Internet
Então, basicamente, temos um back-end hospedado na nuvem. Esse back-end é composto por servidores Web (Django / Python), bancos de dados (Postgresql), RabbitMQ e trabalhadores (aipo) Também temos componentes de hardware em todo o mundo. Esse ...
RabbitMQ e segurança de encadeamento Java de canais
neste guiahttps://www.rabbitmq.com/api-guide.html [https://www.rabbitmq.com/api-guide.html]O pessoal do RabbitMQ declara: Canais e considerações de simultaneidade (segurança de threads) Instâncias de canal não devem ser compartilhadas entre ...
Projeto Spring AMQP com 2 filas
Estou trabalhando em um projeto que envolve 2 filas e múltiplos ouvintes interagindo com eles. Fluxo: Uma nova solicitação HTTP chega ao servidor e é convertida em um objeto que será a mensagemEsta mensagem deve ser publicada em duas filasTenho ...
Definir políticas rabbitmq no arquivo de configuração
Eu gostaria de definir o espelhamento para todas as minhas filas por padrão. Atualmente tenho que usarrabbitmqctl quando o nó estiver ativo: rabbitmqctl set_policy ha-all "" '{"ha-mode":"all"}'Se um dos meus nós falhar, eu precisaria me lembrar ...
Erro no aipo: result.get atinge o tempo limite
Instalei o Aipo e estou tentando testá-lo com oAipo Primeiros Passos Doc [http://docs.celeryproject.org/en/latest/getting-started/first-steps-with-celery.html] . Tentei usar o Redis e o RabbitMQ como corretores e back-end, mas não consigo obter ...
Suporte assíncrono RabbitMQ
O cliente RabbitMQ .NET possui algum tipo de suporte assíncrono? Gostaria de poder conectar e consumir mensagens de forma assíncrona, mas ainda não encontrei uma maneira de fazer isso. (Para consumir mensagens, posso usar o ...
Re-enfileire a mensagem na exceção
Estou procurando uma maneira sólida de re-enfileirar mensagens que não puderam ser tratadas corretamente - no momento. Eu estive ...