Let's Code: Spring Integration, part 1

Hi, Spring fans! Integration is at the heart of everything any major business does. The world isn't just REST and unicorns! In this video, we're going to explore Spring's swiss army knife of integration: Spring Integration

[@romanchumak1586]

Thank you Josh this is great tutorial. Is it possible that you show how to combine RabbitMQ with MQTT and make some sort of load balancer for multiple clients (producer and consumer)

[@Austin_Lee777]

great video ! i like it

[@coffeesoftware]

That’s great to hear ! Thanks for the kind words and for joining me on this adventure

[@modex20]

Hey Josh. I'm looking to poll from a mongodb source that queries for records in a "ready" state. I also need to change those records from "ready" to "processing" so that another poller doesn't pick up the same records while they are already being processed. After each record is processed, I need to update the state to "done". The processing involves delivering a message to a websocket (probably abstracted behind a message channel?). Can IntegrationFlow help with this? It seems like I would need a .handle() to first flip from ready to processing, and then a .channel() to deliver it to another channel to be delivered, followed by another .handle() to mark it complete. Does that make sense? Also, I would need create these IntegrationFlows dynamically at runtime for each websocket session, since the query would old care about documents associated with a particular session id specified by the websocket during handshake. That also means I would need to dynamically create message channels at runtime as well. Is this something that can be done with spring integration?

[@JamesStansell]

Do you look at the Kafka support in any of these Spring Integration sessions?

[@coffeesoftware]

Not yet, but it’s 100% on the list to look at, both when using Spring Integration, and as a standalone treatment

[@sergeyshehovtsov3434]

hi, great video. But there is a problem, I watched the video, I go to your repository and I see that the code that you wrote on the video no longer exists ??? yes i see the base folder and many new modules in this thread but where is the code you showed in the video? take this into account in the future. It's a pleasure to listen and watch you, interesting topics

[@coffeesoftware]

Thanks for the kindness. I’m not sure why the code isn’t there. Maybe it’s in earlier revisions?

[@sergeyshehovtsov3434]

@@coffeesoftware do you have the video code? can you push it?

[@coffeesoftware]

All I have is in github.com/coffee-software-show/lets-code-spring-integration

[@minhduccao9955]

how can we manage transaction inside spring integration

[@coffeesoftware]

As long as you’re not doin asynchronous dispatch into MessageChannels, the publish should be within a transaction’s boundaries. See the docs or www.baeldung.com/spring-integration-transaction

[@shobhit321]

Lets say i have 2 apps , i send a message from app1 on a channel where this channel is initialised, app2 wants to receive this mesaage from the channel in app1. The channel is of default type. Is it possible to send message from app1 to app2. How is it possible as both app1 and app2 are 2 jvms?

[@coffeesoftware]

Absolutely! Stick an outbound adapter on the end of one channel (on the producing app) and an inbound adapter on the beginning of the consuming app. The outbound and inbound adapters could, for example, support communication with FTP, email, AMQP, JMS, Kafka, etc etc

[@WLKNrun]

😺

[@coffeesoftware]

I hope that means you enjoyed it :)