I’m trying to implement a dynamic Spring Integration Router that changes its dynamicChannels based on the members in a Hazelcast cluster. I’m doing this to achieve partitioned distribution of messages. I use Hazelcast’s partition tables to decide on the partition (and thus the member) which will need to handle a specific Message (based on a key in the Message). I use Hazelcast’s MembershipListener to dynamically add/remove MessageChannels. The implementation of the router: