Resultados da pesquisa a pedido "spring-rabbit"
RabbitMQ basic.get e reconhecimento
Estou invocando: GetResponse response = channel.basicGet("some.queue", false); // no auto-ack .... channel.basicAck(deliveryTag, ...);No entanto, quando invocobasicGet, as mensagens na fila permanecem em "Pronto", em vez de em "Não ...
Mensagem Spring Cloud Stream de / para configuração de conversão JSON
Estou usando o Spring Cloud Stream, com o encadernador RabbitMQ. Funciona muito bem combyte[] carga útil e serialização nativa Java, mas preciso trabalhar com carga JSON. Aqui está a minha classe de processador. @EnableBinding(Processor.class) ...
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 ...
Qual é a diferença entre contagem de pré-busca vs não ack em rabbitmq
Preciso saber qual é a diferença entre pré-busca e contagem no ack no rabbitmq? Também qual é a diferença entre as seguintes instruções: - se eu definir a contagem de pré-busca, digamos 10 10 threads de consumidor são criados? Ou - se eu ...
Como conectar-se ao processamento de mensagens antes / depois usando @RabbitListener
Problema:Estou migrando da interface MessageListener impl para @RabbitListener. Eu tinha uma lógica como essa em que eu estava processando as mensagens "pré" e "post" em um MessageListener herdado por várias classes exemplo: public ...
O envio de confirmação para o servidor rabbitmq depende do conversor e do ouvinte
Antes de tudo, apresento o contexto do meu caso: estou usandospring-boot espring-rabbitmq. Está funcionando para mim, você deve saber que devo ter implementado o conversor personalizado para mensagens recebidas. (1)A partir deste conversor pode ...
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 rabbit amqp @RabbitListener configure o número mínimo e máximo de consumidores
Eu estou usando a anotação @RabbitListener da mola amqp rabbit de: artefato spring-rabbit-1.7.1.RELEASE Gostaria de saber se existe uma maneira de configurar para cada fila o número de consumidores? Pesquisei na documentação e não encontrei nada ...
Como iniciar, parar e reconectar os contêineres do rabbitmq listener da primavera e suas conexões?
Eu tenho uma conexão à Internet em que o gateway de saída muda periodicamente. Estou recebendo uma notificação de evento ou retorno de chamada no meu aplicativo de primavera alguns segundos antes que isso aconteça. Gostaria de interromper meus ...
Enviar arquivos através do RabbitMQ
É uma boa ideia enviar arquivos com tamanho de cerca de 1 Mb através do RabbitMQ? Quero enviar uma mensagem no formato json com campos binários correspondentes aos arquivos. E como fazê-lo corretamente usando spring-amqp? Apenas publicando ...
Página 1 do 2