Resultados da pesquisa a pedido "spring-amqp"
Teste de Integração e Rosqueamento RabbitMQ
Eu escrevi um consumidor RabbitMQ implementando a interface MessageListener e configurando um SimpleMessageListenerContainer. Está funcionando bem quando eu testá-lo manualmente. Agora eu gostaria de escrever um teste de integração que: Cria uma ...
Como obter simultaneidade com um MessageListener não seguro para threads
A resposta paraessa questão [https://stackoverflow.com/questions/23341811/how-is-concurrency-in-spring-amqp-listener-container-implemented] explica como usar o escopo do protótipo com<rabbit:listener-container/> no Spring AMQP quando o ouvinte ...
Spring amqp com RabbitMq: a mensagem não é circulada de volta à fila ativa após cair da fila de devoluções
Estou tentando alcançaresta [http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/2013-April/026489.html]. Existem tantas respostas conflitantes para saber se é possível ou não. De acordo com o link anterior, não é possível. Mas em outra ...
Spring AMQP v1.4.2 - Problema de reconexão de coelho em falha de rede
Estou testando o seguinte cenário no Spring AMQP v1.4.2 e ele falha ao se reconectar após uma interrupção na rede: Inicie o aplicativo spring que consome mensagens de forma assíncrona usando rabbit: listener-container e rabbit: ...
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 ...
Como a simultaneidade no Spring AMQP Listener Container é implementada?
Minha configuração XML do contêiner: <rabbit:listener-container connection-factory="myConnectionFactory" acknowledge="none" concurrency="10" requeue-rejected="false"> <rabbit:listener ref="myListener" queues="myQueue"/> ...
Como parar de consumir mensagens com @RabbitListener
Quando eu uso o MessageListenerAdapter para manipular a mensagem, eu poderia chamar SimpleMessageListenerContainer.stop () para interromper o consumo da fila. Mas depois que mudo para usar o @RabbitListener para ouvir, não consigo encontrar um ...
rabbitmq com spring amqp - mensagens bloqueadas no caso de AmqpException
Estou lançando uma AmqpException dentro do meu consumidor. Minha expectativa é que a mensagem retorne à fila na ordem FIFO e seja reprocessada em algum momento no futuro. Parece que o Spring AMQP não libera a mensagem de volta para a fila. Mas, ...
Autorização OAuth2 com Spring Security e Rabbitmq
Atualmente, temos vários microsserviços Spring que estão se comunicando com pontos de extremidade REST e filas RabbitMQ. Acabamos de implementar a segurança do OAuth2 em todos os serviços e os pontos de extremidade REST são ...
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: