Resultados da pesquisa a pedido "rabbitmq"
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 ...
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 ...
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 ...
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 ...
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 ...
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 ...
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 ...
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 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 ...
Como criar um cliente AMQP erlang em Mongooseim
Eu sou novo em erlang. Estou tentando criar a biblioteca cliente RabitMQ Erlang AMQP com minha fonte de mangusto para que eu possa usar a biblioteca nos meus módulos mongooseim. Eu baixei a fonte da biblioteca ...