Resultados da pesquisa a pedido "rabbitmq"
Como usar o Rabbit dentro de um arquivo gitlab-ci.yml?
Eu quero testar comgitlab-ci.yml um servidor rpc nameko. Eu não posso conseguir fazer o Rabitt trabalhar dentro.gitlab-ci.yml:: image: python:latest before_script: - apt-get update -yq - apt-get install -y python-dev python-pip tree - curl ...
aipo 'Worker-n' pid: xxxx saiu com 'exitcode 1' quando importo o hmmlearn
No meu arquivo tasks.py, quando importo o hmmlearn, from hmmlearn import hmme inicio meus trabalhadores de aipo, recebo o seguinte erro [2017-06-14 09:18:27,638: INFO/MainProcess] Received ...
Tendo problemas para lidar com exceções no Spring Integration
Eu sou novo na integração de primavera e estou confuso sobre como enviar mensagens de erro para uma fila de erros designada. Quero que a mensagem de erro seja um cabeçalho na mensagem original e termine em uma fila separada. Eu li que isso pode ...
Fluxo de ar: tarefas na fila, mas não em execução
Eu sou novo no fluxo de ar e estou tentando configurá-lo para executar pipelines ETL. Eu consegui instalar fluxo de arpostgressalsãorabbitmqEu sou capaz de testar executar o turtorial dag. Quando tento agendar os trabalhos, o agendador é capaz ...
Devo fechar o canal / conexão após cada publicação?
Estou usando o amqplib no Node.js e não sou claro sobre as práticas recomendadas no meu código. Basicamente, meu código atual chama oamqp.connect() quando o servidor Nó é inicializado e, em seguida, usa um canal diferente para cada produtor ...
Trocando o MSMQ pelo RabbitMQ no NServiceBus
Udi mencionaaqui [http://forums.asp.net/p/1553491/3814352.aspx]que "as pessoas trocaram a camada MSMQ do NServiceBus e conectaram o RabbitMQ em seu lugar". Estou procurando fazer o mesmo com o objetivo final de poder executar um aplicativo ...
Mensagem atrasada no RabbitMQ
É possível enviar mensagem via RabbitMQ com algum atraso? Por exemplo, desejo expirar a sessão do cliente após 30 minutos e envio uma mensagem que será processada após 30 minutos.
Batida de aipo: limite à instância de tarefa única por vez
Eu tenho aipo e aipo (quatro trabalhadores) para executar algumas etapas de processamento a granel. Uma dessas tarefas é mais ou menos na linha de "para cada X que não tenha um Y criado, crie um Y". A tarefa é executada periodicamente a uma taxa ...
Criação de fila dinâmica com RabbitMQ
Eu tenho aprendido várias topologias do RabbitMQ, no entanto, não encontrei nenhuma referência à criação de fila dinâmica (também conhecida como Declare Queue) emitida por um produtor. A idéia seria criar filas dinamicamente, dependendo de um ...
RabbitMQ - Ordem de entrega da mensagem
Preciso escolher um novo broker de filas para o meu novo projeto. Desta vez, preciso de uma fila escalável que suporte pub / sub, e manter a ordem das mensagens é uma obrigação. Eu li o comentário de Alexis: Ele escreve: "De fato, achamos que ...