spring - Spring Integration AMQP

Question

キューでメッセージを受信し、2 つのステップを並行して実行したい、Spring 統合の学習を開始しました。ステップ 1 -> Bean を使用して処理する ステップ 2 -> 変換して、別のキューに送信します。何かのようなもの ：

return IntegrationFlows.from(Amqp.inboundAdapter(connectionFactory, "queue1")
            .configureContainer(simpleMessageListenerContainerSpec -> {
                simpleMessageListenerContainerSpec.concurrentConsumers(3);
            }))
            .log(message -> "SERVICE EVENT QUEUE : Received Message : " + message.getPayload())
            .handle(serviceBean, "process")
            .<String,String>transform(String::toLowerCase)
            .log(message -> "SERVICE EVENT QUEUE : Transformed Message : " + message.getPayload())
            .handle(
                    Amqp.outboundAdapter(rabbitTemplate)
                            .exchangeName("exchange")
                            .routingKey("queue2.routing"))
            .get();

私は何が欠けていますか？最初のハンドルの後のアクションが実行されていません。この部分を正しく理解していないと思います。また、これらの2つのステップを並行して行うにはどうすればよいですか?