Resultados da pesquisa a pedido "amqp"
Como retirar uma mensagem no RabbitMQ?
Eu tenho algo como uma fila de trabalhos no RabbitMQ e, mediante uma solicitação para cancelar um trabalho, gostaria de retirar as tarefas que ainda não começaram a processar (suas mensagens não foram confirmadas), o que corresponde à retirada ...
Recuperando o Número de Mensagens Não Reconhecidas na Fila RabbitMQ do Java / Spring
Existe alguma maneira de retornar o número de mensagens que não são reconhecidas?Eu estou usando este código para obter o número de mensagens na fila:
DDS vs AMQP vs ZeroMQ [fechado]
Eu queria um feedback sobre se minhas avaliações e preocupações estão corretas. Estive pesquisando os três Data Service Service, AMQP e ZeroMQ há algum tempo para criar uma camada de transporte de dados em um datacenter. Todos os três parecem ...
Sobrecarga de consumidor RabbitMQ
Eu tenho lido sobre os princípios das mensagens AMQP confirma. ( https://www.rabbitmq.com/confirms.html [https://www.rabbitmq.com/confirms.html]) Artigo realmente útil e bem escrito, mas uma coisa em particular sobre os agradecimentos dos ...
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/] ...
Em quais domínios o middleware orientado a mensagens como o AMQP é útil?
Que problema o MOM (Message Oriented Middleware) resolve? Escalabilidade? Integração? Em qual domínio eles são normalmente usados e em quais domínios eles são tipicamentenão usava? Por exemplo, digamos, o Google está usando essa solução para ...
Como obter o Spring RabbitMQ para criar uma nova fila?
Na minha (limitada) experiência com rabbit-mq, se você criar um novo ouvinte para uma fila que ainda não existe, a fila será criada automaticamente. Estou ...
Usando o RabbitMQ (cliente Java), existe uma maneira de determinar se a conexão de rede é fechada durante o consumo?
Estou usando o RabbitMQ no RHEL 5.3 usando o cliente Java. Eu tenho 2 nós (máquinas). O Nó1 está consumindo mensagens de uma fila no Nó2 usando a classe auxiliar Java QueueingConsumer. QueueingConsumer consumer = new ...