Http.outboundGateway上的Spring Integration DSL OAuth
Http.outboundGateway是Spring Integration DSL中的一个组件，用于发送HTTP请求并接收响应。它可以与OAuth（开放授权）进行集成，以实现安全的身份验证和授权。
OAuth是一种开放标准，用于授权第三方应用程序访问用户资源，而无需共享用户的凭据。它通过授权服务器颁发访问令牌，使第三方应用程序能够代表用户访问受保护的资源。
在使用Http.outboundGateway上的Spring Integration DSL时，可以通过配置OAuth认证来确保请求的安全性。具体步骤如下：
- 配置OAuth客户端凭据：在应用程序中配置OAuth客户端凭据，包括客户端ID和客户端密钥。这些凭据将用于与授权服务器进行身份验证和授权。
- 配置OAuth授权服务器：指定授权服务器的URL和其他必要的参数。这些信息将用于与授权服务器建立连接并获取访问令牌。
- 配置Http.outboundGateway：使用Http.outboundGateway组件发送HTTP请求。在配置中，指定目标URL、HTTP方法和请求头等信息。
- 配置OAuth认证：在Http.outboundGateway配置中，添加OAuth认证配置。包括指定OAuth客户端凭据和授权服务器的详细信息。
通过以上步骤，Http.outboundGateway将使用OAuth认证来发送HTTP请求。它将自动处理与授权服务器的通信，并在每个请求中包含正确的身份验证和授权头。
这种集成可以在需要与需要OAuth认证的外部服务进行通信的场景中使用。例如，当与需要用户身份验证的API进行交互时，可以使用Http.outboundGateway和OAuth认证来确保请求的安全性。
腾讯云提供了多个与云计算和HTTP请求相关的产品，可以与Spring Integration DSL和OAuth集成使用。以下是一些推荐的腾讯云产品和产品介绍链接地址：
- 腾讯云API网关：https://cloud.tencent.com/product/apigateway
- 腾讯云云函数（Serverless）：https://cloud.tencent.com/product/scf
- 腾讯云容器服务（TKE）：https://cloud.tencent.com/product/tke
- 腾讯云对象存储（COS）：https://cloud.tencent.com/product/cos
- 腾讯云数据库（TencentDB）：https://cloud.tencent.com/product/cdb
请注意，以上链接仅供参考，具体的产品选择应根据实际需求和项目要求进行评估和决策。
相关·内容
我是Spring-Integration的新手，一直在尝试完成一些简单的任务。我从来没有接触过OAuth，并且需要一个带有OAuth的rest服务，所以我希望有人能向我展示一个在Java DSL中使用OAuth的示例。我目前正在从Rabbit获取消息，并将其转换为JAVA POJO，然后将其发送到新的通道以发布到Rest服务，但我需要首先在服务器上进行身份验证。正如我所说的，对SI和OAuth来说是新的，并且正在寻找一些指针。我就是找不到任何关于OAuth的数字用户线路
@Bean
public IntegrationFlow amqpInboundGateway(Connec
浏览 8提问于2019-11-06得票数 0
我正在尝试将下面的spring集成示例转换为Java版本。
我们需要稍微修改这个项目的版本才能在生产环境中工作。我的问题是，在启动应用程序时，我一直会得到以下异常。
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'httpInboundGateway' defined in org.springframework.platform.proxy.TunnelApplication: Bean instantiation via factory metho
浏览 3提问于2017-02-06得票数 0
回答已采纳
我想使用Java DSL进行Spring Integration，但我不知道如何在转换期间使用消息头。 我的旧实现有一个Transformer，如下所示： @Transformer(inputChannel = "inputChannel", outputChannel = "outputChannel")
public EventB transform(
EventA eventA,
@Header("a_header") String aHeader,
@Header("other_h
浏览 36提问于2019-02-26得票数 1
回答已采纳
由于春季集成依赖关系，我们在使用logConsumer函数时遇到了问题。请帮我查一下。
应用程序启动失败
描述：
试图调用不存在的方法。这一企图是在以下地点进行的：
org.springframework.cloud.fn.consumer.log.LogConsumerConfiguration.logConsumerFlow(LogConsumerConfiguration.java:46)
不存在以下方法：
org.springframework.integration.dsl.IntegrationFlowBuilder.log(Lorg/springframework/integ
浏览 2提问于2021-09-25得票数 0
回答已采纳
我在使用Http.outboundGateway时看到以下错误，有人能帮我找出错误的地方吗
@Bean
public IntegrationFlow syncProcessFlow() {
return
// dsl code to fetch a message from Queue
...
.<Event, EventType>route(event -> event.getType(), mapping -> mapping
.channelM
浏览 0提问于2018-04-11得票数 0
回答已采纳
我使用的是Spring Cloud Streams和com.azure.spring:azure-spring-cloud-stream-binder-eventhubs:2.8.0，，我使用的是Supplier。
它适用于Spring boot 2.3.12.RELEASE。
但是，如果我转到spring boot版本>= 2.4.0，则会得到以下错误：
An attempt was made to call a method that does not exist. The attempt was made from the following location:
org.
浏览 1提问于2021-09-10得票数 1
我已经使用最新的可用版本设置了一个新的Spring Boot + Spring Integration + Spring Integration Java DSL项目。项目构建得很好，但是，当我运行应用程序时，我得到：
Caused by: java.lang.NoSuchMethodError: org.springframework.integration.dsl.StandardIntegrationFlow.isRegisterComponents()Z
at org.springframework.integration.dsl.config.IntegrationFlowB
浏览 13提问于2018-02-13得票数 2
回答已采纳
嗨，我正在尝试添加，但是不知道下面的场景的错误是什么。
我的IntegrationConfig如下所示
@Configuration
@EnableIntegration
@IntegrationComponentScan
public class IntegrationConfig {
@Bean
public IntegrationFlow sayHelloFlow(){
String uri = "http://localhost:8081/hellos";
return IntegrationFlows.from("
浏览 5提问于2021-08-18得票数 0
在流程定义中，我一定遗漏了一些非常基本的东西。得到这个错误
is a one-way 'MessageHandler' and it isn't appropriate to configure 'outputChannel'. This is the end of the integration flow.
我的理论是，由于适配器是单向组件，因此在流程的句柄步骤中没有生成输出。这就是为什么这会导致运行时错误。但是，不知道如何定义这个简单的流。
代码：
@Autowired
private JmsMessagingTemplate jmsMessagin
浏览 3提问于2016-01-21得票数 2
回答已采纳
我想了解哪里是读取头的最佳位置，并在我的IntegrationFlow层中使用它们。
ServiceController.java
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.Requ
浏览 3提问于2021-08-19得票数 0
回答已采纳
我在这个版本中使用spring集成和java依赖关系。
spring-integration-JDBC-5.0.0M6
弹簧-集成-ws- 5.0.0M6
春季-整合-http- 5.0.0M6
弹簧-集成-jmx- 5.0.0M6
弹簧-集成-核心- 5.0.0M6
java 1.2.2RELEASE
由于新的JdbcMetadataStore，我必须使用5.0.0M6版本。
上周，我使用了SpringIntegration4.3.11RELEASE和java-dsl-1.2.2RELEASE，我的应用程序开始工作。
升级过程之后，将引发此运行时异常：
Cau
浏览 4提问于2017-09-08得票数 1
回答已采纳
我正在用一个新的spring集成版本测试我现有的应用程序。不幸的是，我得到了一个意外的异常，如下所示：
Caused by: java.lang.UnsupportedOperationException: null
at org.springframework.integration.dsl.StandardIntegrationFlow.configure(StandardIntegrationFlow.java:64) ~[spring-integration-java-dsl-1.2.1.RELEASE.jar:na]
at org.springframework.in
浏览 3提问于2017-01-27得票数 3
回答已采纳
使用Spring、Integration和DSL尝试一个非常基本的JMS接收器。我曾经研究过基于的XML，但对Spring和DSL来说还是个新手。
到目前为止，这是一个代码示例。
@SpringBootApplication
@IntegrationComponentScan
@EnableJms
public class JmsReceiver {
static String mailboxDestination = "RETRY.QUEUE";
@Configuration
@EnableJms
@IntegrationComponen
浏览 5提问于2016-01-08得票数 4
回答已采纳
1回答
我在这里做一个分散的收集流。在流的末尾，我想打印从应答通道到控制台的消息。这里有3个API调用，其中2个是GET调用，1个是POST调用(POST调用正在执行一些数据库操作)。所有API都在运行并得到结果，但我无法打印消息。
//Configuration class
package com.lbg.scattergather.configuration;
import com.lbg.scattergather.model.Company;
import org.springframework.context.annotation.Bean;
import org.springframe
浏览 7提问于2022-06-19得票数 0
我试图使用将下面的spring集成项目转换为java配置版本。我没有多少运气，我也找不到dsl上的文档来帮助我理解这个框架来完成这个任务。
这是我正在转换的项目。它使用xml配置。
基本上，它需要一个http请求，然后通过rabbitmq将其隧道到另一边的目标应用程序。关于项目应该做什么的良好描述可以在上面的链接上找到。
我的应用程序和上面列出的github应用程序的主要区别是，我的应用程序基于spring引导1.5.1.RELEASE，而原始应用程序是基于1.1.4 based快照。此外，原始项目使用spring集成xml命名空间支持，即int-http:入站-网关、int-出站-网关、in
浏览 0提问于2017-02-06得票数 0
回答已采纳
1回答
我试图使用spring-integration-dsl-groovy，运行一个简单的spring应用程序，但是我得到了以下错误
org.springframework.web.util.NestedServletException:处理失败；嵌套异常为java.lang.NoClassDefFoundError: org/Message框架/integration/Message
有谁可以帮我？
这是我的密码
@RestController
class SampleController{
@RequestMapping("/welcome")
Stri
浏览 2提问于2015-06-04得票数 1
当试图向http出站网关发送请求时，我收到了以下错误。在得到响应后，我将json有效负载转换为我所读过的其他帖子中的对象列表--这可能是服务激活器或转换器的问题。我还在努力弄清楚EIP和SI的情况。
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'httpPostAtms' defined in class path resource [com/backbase/atm/config/InfrastructorConfig.class]: Be
浏览 0提问于2017-07-05得票数 1
回答已采纳
我有一个基于的应用程序，该应用程序的一部分具有以下配置。
upgrade在4.3.10.RELEASE版本中运行良好，但现在我正试图将版本升级到5.1.5.RELEASE，并且应用程序无法从下面提到的例外开始。
我能够解决更改配置的问题，但我想知道为什么要更改这个配置。
在4.3.10中工作的旧配置：
@Bean
public IntegrationFlow mainFlow(@Qualifier("initChannel") PublishSubscribeChannel inboundChannel, TaskExecutor taskExecutor,
浏览 4提问于2020-09-21得票数 0
回答已采纳
如何使Spring在中工作？需要帮助将其添加到IntegrationFlow DSL中
将其添加到transform()中，但是它没有被反映出来。
spring.sleuth.baggage.local-fields: customField
spring.sleuth.baggage.correlation-fields: customField
@Bean
public BaggageField customField() {
return BaggageField.create("customField");
}
@Bean
public ScopeDeco
浏览 28提问于2022-01-06得票数 1
我使用了最新的，并在消费者配置上卡住了。
这是我的使用者配置：
@Configuration
public static class ConsumerConfiguration {
@Autowired
private KafkaConfig kafkaConfig;
private Log log = LogFactory.getLog(getClass());
@Bean
public ConsumerFactory<String, String> consumerFactory() {
Map<String,
浏览 2提问于2016-09-21得票数 3
回答已采纳
1回答
我有一个要求，解压缩，文件和处理其内容。在zip文件中，可以有两种类型的文件单独或公司。它可以通过文件名来区分。在处理完所有文件后，它应该调用另一个程序模块，并将处理后的文件存档到不同的位置。希望使用Spring集成来实现同样的功能。我试图通过下面的代码来实现这一点，但是它在基于文件名的路由过程中产生了问题。我使用的是JDK 8，Spring 5
.<File, Boolean>route(new Function<File, Boolean>() {
@Override
public B
浏览 1提问于2018-08-29得票数 1
回答已采纳
我使用Spring Integration，Java DSL (release 1.1.3)，我的org.springframework.integration.dsl.IntegrationFlow定义如下
return IntegrationFlows.from(messageProducerSpec)
.handle(handler)
.handle(aggregator)
.handle(endpoint)
.get();
}
messageProducerSpec是org
浏览 6提问于2016-09-20得票数 4
回答已采纳
我跟着这个医生
并添加maven适当性：
<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-sftp</artifactId>
<version>5.0.0.M6</version>
</dependency>
<dependency>
<groupId>org.springframework
浏览 1提问于2017-10-13得票数 2
回答已采纳
我找不到一个简单的例子来对spring集成dsl进行单元测试，它涉及到从队列中提取消息并进行rest调用。
我看了示例，但对下面要编写单元测试的代码的限定符等不太清楚。
IntegrationFlows.from(Jms.inboundGateway(connectionFactory)
.id("inputChannel")
.destination(sourceQueue)
.jmsMessageConverter(new MarshallingMessageConverter(jaxbMars
浏览 0提问于2018-04-20得票数 2
因此，Spring Integration 5引入了入站通道的目录扫描器的概念，我非常希望将其用于我的ftp通道。 但是，我不确定如何使用Java DSL来配置它。docs说我可以用XML语言在scanner inbound-channel-adapter上设置扫描仪。但是，我使用的是Spring Integration DSL via IntegrationFlow，在使用这种方法时，我似乎无法设置这个目录扫描器…… 这是真的吗？有没有办法用IntegrationFlow设置目录扫描器？我知道我可以使用更正式的Java Config方法，但我不希望这样做，因为那会有很多工作要做。
浏览 15提问于2019-02-26得票数 1
回答已采纳
1回答
我正在从1.x迁移到springBootVersion = '2.2.10.RELEASE‘，当我针对它进行编译时，我有spring-integration-core-5.2.8.RELEASE.jar，但我找不到它。 import org.springframework.integration.dsl.amqp.Amqp; 文档显示，由于重复声明，我不需要声明dsl包。我是不是遗漏了什么？
浏览 12提问于2020-10-17得票数 0
我已经为Spring Integration编写了基于Java DSL文档的代码。当我运行代码时，我一直收到以下警告，即使日志还显示消息已成功传递给两个订阅者。
2021-03-04 17:21:25.589 WARN 46929 --- [enerContainer-1] bleJmsChannel$DispatchingMessageListener : Dispatcher has no subscribers for jms-channel 'application.jmsPublishSubscribeChannel'.
org.springframework.i
浏览 48提问于2021-03-05得票数 1
回答已采纳
1回答
我是Spring的新手，我正在尝试开发一个应用程序，该应用程序简单地(1)轮询一个扩展名为.dat的新文件，其中包含csv格式的数据(2)为每一行初始化类RecordDTO的域POJO对象，最后(3)将该对象作为有效负载发送到带有POST的REST服务。
为此，我尝试使用Java进行Spring集成。
我遇到的问题是以下VerifyError / HttpRequestExecutingMessageHandler overrides final method onInit.异常。
2016-07-22 10:01:38.965 ERROR 4460 --- [ main]
浏览 3提问于2016-07-22得票数 0
回答已采纳
1回答
对于Spring Integration DSL的文件写入支持，有没有什么可行的例子？我找不到任何关于DSL实现的东西(例如，集成流中的handle()步骤，等等)谢谢。
浏览 4提问于2018-05-30得票数 1
1回答
我正在创建一个新的流，并从几乎为空的定义开始
@Bean
public IntegrationFlow routerFlow() {
return IntegrationFlows
.from(routerInputChannel())
.channel(routerOutputChannel())
.get();
}
到目前一切尚好。但是如果我添加简单的wireTap行
@Bean
public IntegrationFlow routerFlow() {
return IntegrationFlows
浏览 1提问于2017-07-17得票数 2
回答已采纳
我正在从学习Spring集成，并且我知道如何在收到消息时启动作业。现在，我想获得消息的名称和路径(这是一个文件)。下面是我的工作代码。但是，如果取消对setFileParameterName方法的注释，则会得到以下异常：
java.lang.IllegalArgumentException: Found ambiguous parameter type [class java.lang.String] for method match: [public void com.example.batchprocessing.FileMessageToJobRequest.setFileParamet
浏览 8提问于2020-04-08得票数 0
回答已采纳
我使用的是Spring Integration Java DSL v1.2.2，按照一些示例，我尝试编写一段代码来轮询文件夹
return IntegrationFlows
.from(Files.inboundAdapter(new File("/tmp/foo")))
.handle((p, h) -> fileProcessor.process(p))
.get();
无法编译此代码，因为
"Cannot resolve method 'from(org.springfr
浏览 2提问于2017-06-13得票数 0
回答已采纳
1回答
我们正在尝试使用使用DSL的HTTP调用REST。我们可以使用GET和POST进行呼叫，并按预期的方式获得响应。但是，在使用DSL进行此调用时，我们无法找到传递http头的方法。有很多关于XML方法的文章，但却找不到DSL的文档。
return IntegrationFlows.from("FileContentChannel")
.handle(Http.outboundGateway("http://host:port/paymentinfo/")
.charset("
浏览 0提问于2016-10-25得票数 1
回答已采纳
官方Spring Integration DSL参考文档在https://docs.spring.io/spring-integration/reference/html/dsl.html#java-dsl的第一部分中提供了以下代码示例 @Configuration
@EnableIntegration
public class MyConfiguration {
@Bean
public AtomicInteger integerSource() {
return new AtomicInteger();
}
@Bean
publ
浏览 31提问于2021-07-16得票数 1
回答已采纳
我正在用DSL编写basic-amqp example (https://github.com/spring-projects/spring-integration-samples/blob/master/basic/amqp/src/main/resources/META-INF/spring/integration/spring-integration-context.xml)的示例代码 @Bean
public IntegrationFlow receiveGreetingFromGreetingQueueToConsole(ConnectionFactory connectionFa
浏览 12提问于2020-07-17得票数 0
回答已采纳
我有一个要求，当它失败时，我需要进行rest调用，我必须重试3次，根据收到的状态代码，我需要执行不同的操作，我找不到一个合适的spring集成dsl示例。如何配置错误处理程序并重试
@Bean
public IntegrationFlow performCreate() {
return IntegrationFlows.from("createFlow")
.handle(Http.outboundGateway("http://localhost:8080/create")
.httpM
浏览 2提问于2018-04-11得票数 3
回答已采纳
我正在尝试连接两个队列通道(由JDBC支持)。
@Configuration
public class DemoIntegration {
@Bean
public IntegrationFlow flow(MessageChannel firstJDBCChannel,
MessageChannel secondJDBCChannel) {
return IntegrationFlows.from(firstJDBCChannel)
.bridge(bridgeHa
浏览 8提问于2017-12-09得票数 0
回答已采纳
我有这样的流程：
@Bean
public IntegrationFlow flow(){
return IntegrationFlows.from(QueueMessageSink.INPUT)
.transform(Transformers.fromJson(QueueMessage.class))
.<QueueMessage, DTOMessage> transform(queueMessage -> new DTOMessage(/* transform logic */))
.handle(Http.outb
浏览 3提问于2019-04-09得票数 0
2回答
卡夫卡不起作用
、、
我试图探索使用Kafka和Spring的Spring集成。我正在学习本教程
我正在使用该文档中提供的依赖项，但我得到了以下异常
Caused by: org.xml.sax.SAXParseException: cvc-complex-type.3.2.2: Attribute 'compression-codec' is not allowed to appear in element 'int-kafka:producer-configuration'.
我认为这是一个jar不匹配的问题，但我无法解决它，我试图改变版本很多，但组合并不适合我。请找到我下面的g
浏览 6提问于2017-05-19得票数 0
回答已采纳
我将Spring boot版本从2.0.5.RELEASE升级到2.1.8.RELEASE (因此Spring Integration从5.0升级到5.1)，集成流程中的自动类型转换不再起作用。我习惯于定义一组@IntegrationConverter组件，并在集成流代码中使用transform(Type.class, p -> p)操作进行自动转换，但在新版本中，它似乎被打破了。 <?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache
浏览 51提问于2019-09-13得票数 7
回答已采纳
我有以下简单的代理集成流程。其主要任务是接收来自代理的请求，将其发送到实际端点，获取响应并将其发送回客户端。
@SpringBootApplication
@EnableIntegration
public class IntegrationApp {
@Value("${narko.pin}")
private String pinUrl;
public static void main(String[] args) {
SpringApplication.run(MinzdravApplication.class, args);
}
@Bean
publ
浏览 13提问于2022-08-10得票数 2
回答已采纳
如何使用Spring Integration DSL创建XPath拆分器？与此对应的DSL是什么：
<!-- Split the order into items creating a new message for each item node -->
<int-xml:xpath-splitter id="orderItemSplitter"
input-channel="orderChannel"
output-channel="orderItemsCha
浏览 0提问于2016-03-22得票数 1
我开发了一个自定义的动态FTP组件来处理spring集成dsl。该组件在spring-boot 1.3.0上运行良好。然而，我不得不在我的一些集成中更新spring-boot，以使用屏障dsl功能，版本为1.5.6。
从现在开始，我会收到以下堆栈跟踪的警告，尽管组件仍然可以工作：
pool-4-thread-1] o.s.i.expression.ExpressionUtils : Creating EvaluationContext with no beanFactory
java.lang.RuntimeException: No beanFactory
at org.s
浏览 105提问于2018-08-16得票数 3
如何处理在下面的SpringIntegrationFlow中抛出的错误，只需记录错误并继续下一条记录。同样，应该能够只发送一次电子邮件，而不管有一个或更多的记录失败。是否有类似于Spring的StepListener的东西？谢谢
return IntegrationFlows.from(jdbcMessageSource(), p -> p.poller(pollerSpec()))
.enrichHeaders(Collections.singletonMap(MessageHeaders.ERROR_CHANNEL, appErrorCh
浏览 8提问于2022-01-12得票数 1
回答已采纳
1回答
我有多模块的弹簧引导应用程序。我组织它的方式是，它包含有web类的@SpringBootApplication模块和由web模块导入的其他几个模块(例如，batch-jobs模块)。
web模块包含spring中的所有依赖项：
compile('org.springframework.boot:spring-boot-starter-batch')
compile('org.springframework.boot:spring-boot-starter-data-jpa')
compile('org.springframework.boot:sprin
浏览 6提问于2016-11-29得票数 0
回答已采纳
我有一个Spring Integration的问题。我使用的是Spring Boot 1.4.0.RELEASE，Spring Integration 4.3.1.RELEASE，Spring Integration DSL 1.2.0.M1。
我想要做的是：
我正在编写一个应用程序，它将从FTP和本地文件系统读取文件(使用入站通道适配器)，将文件传输到本地工作目录(使用文件出站网关)，处理这些文件，然后将它们移动到最终目的地(文件出站网关/适配器)。
编辑:最初的问题源于OutboundGateway的错误使用。有关我做错了什么的详细信息，请查看编辑历史记录。
我在连接一个需要来自消息头的信
浏览 5提问于2016-08-19得票数 4
回答已采纳
我能知道如何在Spring Integration Java DSL中调用.handle()的Spel ()(调用Service Activator)吗？
原因是我想调用带参数的服务激活器。对于XML，我可以在表达式属性中使用类似于"@myService.myMethod('param1'，'param2')“的Spel。
我在SI Java DSL中找不到类似的东西
浏览 13提问于2016-08-08得票数 1
我有一个与这个问题非常相似的问题
一个不同之处在于，消息来自Http端点而不是JMS队列。问题是，由于某种原因，消息通道没有被填充，或者它没有被Flux.from()拾取。日志条目显示GenericMessage是从Http Integration flow创建的，使用有效负载作为路径变量，但没有入队/发布到通道？我尝试了.channel(MessageChannels.queue())和.channel(MessageChannels.publishSubscribe())没有任何区别，事件流是空的。代码如下：
@Bean
public Publisher<Message<Str
浏览 6提问于2017-07-13得票数 2
回答已采纳
我正在创建一个通用适配器，它将接受XML消息(带有名称空间)并将其转换为JSON。我可以使用xslt删除名称空间，然后使用JSON转换为org.json，还有一些其他转换和使用SI流- return IntegrationFlows
.from(org.springframework.integration.jms.dsl.Jms.messageDrivenChannelAdapter(
org.springframework.integration.jms.dsl.Jms.container(t
浏览 14提问于2020-04-23得票数 0
我正在使用Spring Integration，并且正在使用文件。我使用提供的DSL来处理我的文件。在我的集成流结束时，我使用Files.outboundGateway(...)将结果输出到一个新文件。然而，我一直收到下面的错误no output-channel or replyChannel header available。根据这篇文章底部的帖子，解决方案是将预期的回复设置为false，但是，我如何使用DSL做到这一点呢？ 下面显示了我在集成流的最后一部分中执行的写入文件的操作。 .handle(Files.outboundGateway(new File(outputFilePath)
浏览 28提问于2021-06-30得票数 0
回答已采纳
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
