Я немного новичок в Spring-Integration и пытаюсь решить некоторые простые задачи. Никогда не касаясь OAuth вообще и имея службу отдыха с OAuth, я надеюсь, что кто-то может показать мне пример использования OAuth с Java DSL. В настоящее время я принимаю сообщение от Rabbit и преобразовываю его в JAVA POJO, а затем отправляю его на новый канал для отправки в службу Rest, но сначала мне нужно пройти аутентификацию на сервере. Как я уже сказал, новичок в 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();
}