Resultados da pesquisa a pedido "rabbitmq"
Aipo: como limitar o número de tarefas na fila e parar de alimentar quando cheio?
Eu sou muito novo no Aipo e aqui está a pergunta que tenho: Suponha que eu tenha um script que deve buscar constantemente novos dados do DB e enviá-los aos trabalhadores usando o Aery. tasks.py # Celery Task from celery import Celery app = ...
Mensagens agendadas / atrasadas no Spring AMQP RabbitMq
Estou lutando muito para descobrir o caminho das mensagens agendadas / atrasadas no Spring AMQP / Rabbit MQ. Depois de muita pesquisa, ainda não sou capaz de fazer isso no Spring AMQP. Alguém pode me dizer como fazeratraso x no Spring AMQP. Quero ...
Desempacotando em uma Interface {} e Executando Afirmação de Tipo
Eu recebo umstring através de um sistema de mensagens rabbitmq. Antes de enviar, eu usojson.Marshal, converta o resultado emstring e envie através do rabbitmq. As estruturas que eu converto e envio podem ser: (alteraram os nomes e o tamanho das ...
Se a conexão deve ser criada sempre que o amqp.Dial estiver seguro ou não em thread
Como é mencionado nos documentos do RabbitMQ, as conexões tcp são caras de fazer. Então, para esse conceito de canal foi introduzido. Agora me deparei com issoexemplo [https://www.rabbitmq.com/tutorials/tutorial-four-go.html]. Nomain() ele cria a ...
Mensagens com letras não entregues não são reencaminhadas para a fila original após ttl
Planejei atrasar o processamento de mensagens na fila seguindo estes dois links link1 [http://yuserinterface.com/dev/2013/01/08/how-to-schedule-delay-messages-with-rabbitmq-using-a-dead-letter-exchange/] ...
como implementar o mecanismo RPC usando RabbitMQ em java
como implementar o mecanismo RPC (produtor e consumidor) usando RabbitMQ em java? Também estou visitando o site oficial http://www.rabbitmq.com/api-guide.html#rpc [http://www.rabbitmq.com/api-guide.html#rpc]mas estou recebendo descrição detalhada ...
Como solicitar ao RabbitMQ que tente novamente quando a exceção de negócios ocorrer no caso de uso do Spring Asynchronous MessageListener
Eu tenho um ouvinte de mensagens do Spring AMQP em execução. public class ConsumerService implements MessageListener { @Autowired RabbitTemplate rabbitTemplate; @Override public void onMessage(Message message) { try { ...
Como você compila uma extensão PHP no Windows com cygwin / mingw?
Eu estou tentando construir oWrapper PHP RabbitMQ [http://code.google.com/p/php-rabbit/]e aWrapper PHP do AMPQ [http://code.google.com/p/php-amqp/]no Windows (64) usando Cygwin. Criei com sucesso a biblioteca C subjacente (librabbitmq.dll), mas ...
Passe o URL para o método de análise em scrapy que foi consumido pelo RabbitMQ
Estou usando o scrapy para consumir a mensagem (url) do RabbitMQ, mas quando uso o yield para chamar o método de análise passando meu url como parâmetros. O programa não vem dentro do método de retorno de chamada. Abaixo está o código a seguir de ...
roblema de instalação do @RabbitMQ no Centos 5.5
Estou tentando colocar o rabbitmq-server-2.4.0 em funcionamento no Centos 5.5 em uma instância do Amazon AW minha instância usa o seguinte kernel: 2.6.18-xenU-ec2-v1.2 Tentei a instalação do erlang e do rabbitmq-server usando: 1) yum repos ...