You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I love the new BlockingQueueItemWriter<O> and BlockingQueueItemReader<I> implementations, but it occurred to me you'd open even more opportunities for users of Spring Integration if you had a MessageChannelItemWriter and MessageChannelItemReader. Behind the scenes a default direct MessageChannel is a Queue, so the default experience could be very similar to with the BlockingQueue equivalents, but MessageChannels can also lead to Spring Integration IntegrationFlows, to websocvkts with Spring MVC 4's WebSocket support, to durable channels backed by JMS, Kafka, etc., to Spring Security interceptors to trap messages, to integration with Spring Cloud Data Flow as an app. All sorts of possibilities.
The text was updated successfully, but these errors were encountered:
Yes, this makes sense and I was planning to add it in the spring-batch-integration module. My goal with the introduction of BlockingQueue reader and writer is to make this architecture style possible and available in the spring-batch-infrastructure module (ie for people who are not using Spring Integration).
I love the new
BlockingQueueItemWriter<O>
andBlockingQueueItemReader<I>
implementations, but it occurred to me you'd open even more opportunities for users of Spring Integration if you had aMessageChannelItemWriter
andMessageChannelItemReader
. Behind the scenes a default directMessageChannel
is aQueue
, so the default experience could be very similar to with theBlockingQueue
equivalents, butMessageChannels
can also lead to Spring IntegrationIntegrationFlow
s, to websocvkts with Spring MVC 4's WebSocket support, to durable channels backed by JMS, Kafka, etc., to Spring Security interceptors to trap messages, to integration with Spring Cloud Data Flow as an app. All sorts of possibilities.The text was updated successfully, but these errors were encountered: