Spring Integration DSL OAuth на Http.outboundGateway

Question

Я немного новичок в Spring-Integration и пытаюсь показать некоторые простые задачи. Я вообще никогда не касался OAuth и требовал службы отдыха с OAuth. Я надеюсь, что кто-нибудь покажет мне пример использования OAuth с Java DSL. В настоящее время я принимаю сообщение от Rabbit и преобразую его в JAVA POJO, а затем отправляю его на новый канал для публикации в службе отдыха, но сначала мне нужно пройти аутентификацию на сервере. Как я сказал, новичок в SI и OAuth и ищу несколько указателей. Я просто не могу найти что-нибудь на DSL с OAuth

    @Bean
    public IntegrationFlow amqpInboundGateway(ConnectionFactory connectionFactory, @Value("${rabbitmq.queue}") String queue) {
        return IntegrationFlows.from(Amqp.inboundGateway(connectionFactory, queue))
                .transform(Transformers.toJson())
                .transform(Transformers.fromJson(Call.class))
                .log(message -> message.getPayload())
                .channel("rabbitOutput")
                .get();
    }

    @Bean
    public IntegrationFlow httpPostAtms( @Value("${alemba.incident.get}") String uri) {

        return IntegrationFlows.from("rabbitOutput")
                .handle(Http.outboundGateway(uri)
                        .httpMethod(HttpMethod.POST)
                        .extractPayload(true))
                .transform(Transformers.toJson())
                .log()
                .get();

    }

Answer 1

Я не знаком с OAuth, но Http.outboundGateway() можно настроить с помощью внешнего RestTemplate, который можно настроить любым возможным способом. Пожалуйста, узнайте больше об OAuth в Spring Security: https://docs.spring.io/spring-security/site/docs/5.2.1.RELEASE/reference/htmlsingle/#oauth2. В Spring Integration ничего не нужно делать по этому вопросу: полностью ответственность за этот проект не лежит