I want to create create a custom spring integration DSL to avoid boilerplate code in our product. More concrete, we are creating a lot of flows where we receive data from an AMQP0.9 queue, transform it, and publish it to an Exchange.