Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Tengo una aplicación que lee de una cola de kafka y sigue así. validate->convert->enrich->persist->notify En el flujo, estoy recopilando algunos puntos de datos de rendimiento y otros en un contenedor de ThreadLocal. En el escenario ideal, estoy enviando esta información a un servicio para que se use posteriormente en informes. . . . Read more
Mis beans/listeners son construidos utilizando IntegrationFlows Ejemplo: @Bean IntegrationFlow registerDevices() { return IntegrationFlows .from(adapter) .channel(channel) .get(); } Existe una manera de detener los listeners después de que ocurra algo, como una llamada a un endpoint o un evento. RabbitListenerEndpointRegistry no funciona, porque no estoy usando @RabbitListener. Existe la posibilidad de . . . Read more
Estoy intentando habilitar métricas para alimentar estadísticas de mensajes desde un gateway RabbitMq <=> MqSeries de spring-integration a Prometheus. La documentación establece que el canal debe extender AbstractMessageChannel para que las métricas se apliquen. Dado que me siento bastante incómodo con los espacios de nombres, no estoy seguro si este . . . Read more
Estamos migrando de RabbitMQ a Redis en nuestras aplicaciones de microservicio. Aquí está nuestro activador de servicio: @ServiceActivator(inputChannel = ApplicationEventChannelNames.REMOTE_CHANNEL) public void handleApplicationEvent(@Header(value = ApplicationEventHeaders.APPLICATION_EVENT) final ApplicationEvent event, @Payload Object message) { … } Inicialmente tuvimos un problema en el que estábamos perdiendo eventos de aplicación en SimpleMessageConverter. Lo solucionamos . . . Read more
En mi código, el adaptador de canal SqsMessageDrivenChannelAdapter está configurado para leer mensajes de la cola de AWS y enviarlos a un canal pollable (cola). Para el canal pollable, un activador de servicio está apuntando para leer el mensaje y procesarlo. Mi pregunta exacta es: ¿cómo hacer que el activador . . . Read more