Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
En mi proyecto Spring, uso un interceptor de canal (registrado con la anotación @GlobalChannelInterceptor) para interceptar mensajes en todos los canales. Quiero que este interceptor se comporte de manera diferente para diferentes canales, por ejemplo, para algunos canales debería agregar un encabezado A, para otros canales debería agregar un encabezado . . . Read more
Estoy utilizando InboundChannelAdapter para obtener datos de una base de datos cada 100000 milisegundos. @InboundChannelAdapter(value = “inboundChannel”, poller = @Poller(fixedDelay=”100000″, maxMessagesPerPoll = “10000”)) A continuación, hay un transformador donde transformo los datos obtenidos en formato JSON. @Transformer(inputChannel = “inboundChannel” , outputChannel = “outChannel”) public Message<string> transformer(Message<><myob>> items) Cuando ejecuto el . . . Read more
Estoy intentando leer datos de GCP pubsub usando DirectChannel (Código de Referencia). Cuando usé directchannel con maxSubscribers ajustado a 1, 2, 5, 10 y 40, 4 hilos comenzaron a procesar mi código para cada unidad de datos proveniente de pubsub, en cada caso. Lo mismo sucedió con PublishSubscribeChannel, donde por . . . Read more
He configurado un adaptador de Imap Idle que está escuchando en una bandeja de correo electrónico, leyendo y analizando el correo. El manejo de estos correos electrónicos se realiza en una clase activadora de servicio. Estos correos electrónicos se generan en masa desde un sistema ERP y tienen adjuntos pesados. . . . Read more
Soy nuevo en Spring Integration y Batch, y quiero desarrollar una aplicación de batch con particionamiento remoto utilizando un maestro y un trabajador. Utilicé Spring Integration y RabbitMQ para la cola de mensajes, la aplicación funciona bien, pero el itemProcessor del trabajador se inicia automáticamente, sin embargo, necesito poder controlar . . . Read more