Tag: SPRING-INTEGRATION
¿Cómo podemos hacer que un BaggageField de Spring Cloud Sleuth funcione en Spring IntegrationFlow? Necesito ayuda para agregarlo en el IntegrationFlow DSL. Lo agregué en un transform(), sin embargo, no se refleja. spring.sleuth.baggage.local-fields: customField spring.sleuth.baggage.correlation-fields: customField @Bean public BaggageField customField() { return BaggageField.create(“customField”); } @Bean public ScopeDecorator mdcScopeDecorator() { return . . . Read more
En nuestra aplicación, estamos utilizando Spring Integration/Soap Web Service y Spring Boot. Tenemos un flujo en Spring Integration que recibe un XML de entrada que tiene una etiqueta llamada <content> que contiene los datos del documento que necesitamos cargar. Dado que es una integración de Spring, recibimos estos datos XML . . . Read more
Sigo recibiendo la siguiente excepción en mi proyecto de Spring Integration: Fallo de ejecución de solicitud HTTP para URI [http://localhost:9502/clients/clientId] en el [bean ‘retrieveClientIdConfigurationFlow.http:outbound-gateway#0’ para el componente ‘retrieveClientIdConfigurationFlow.org.springframework.integration.config.ConsumerEndpointFactoryBean#2’; definido en: ‘class path resource [com/abs/integration/services/RetrieveClientIDConfiguration.class]’; desde la fuente: ‘bean method retrieveClientIdConfigurationFlow’]; la excepción anidada es org.springframework.web.client.RestClientException: No HttpMessageConverter para com.abs.retrieveclientid.request.TransactionType y . . . Read more
¿Podemos utilizar Spring Integration para configurar la inspección de directorios de archivos de manera que: Con 2 servidores configurados, la inspección ocurre en 1 servidor y el procesamiento correspondiente se distribuye entre ambos servidores. También, ¿podemos cambiar la inspección en cualquiera de los servidores en tiempo de ejecución? Editado: Se . . . Read more
He configurado la integración de Spring para sondear un directorio. He configurado el InBoundChannelAdaptor con la configuración de sondeo de máximo mensajes por sondeo = -1 y disparador = PeriodicTrigger(1000) Además, he proporcionado un comparador personalizado al crear el FileReadingMessageSource, para procesar los archivos según la fecha de modificación. FileReadingMessageSource . . . Read more