spring-integration 相关问题

有关Spring Integration项目的问题，请使用此标记。它不适用于将其他Spring项目与其他技术集成的一般问题。

RabbitTemplate的setChannelTransacted标志导致消息未传递到队列中

鉴于我有带有AMQP匿名队列和扇出交换的应用程序：@Bean public Queue cacheUpdateAnonymousQueue（）{return new AnonymousQueue（）; } public static final String ...

rabbitmq spring-integration spring-amqp rabbitmq-exchange spring-integration-amqp

回答 1 投票 0

Spring Integration File Support中的条件文件移动

我正在实现一个Spring Integration工作流程，如下所示。 IntegrationFlows.from（“ inputFileProcessorChannel”）.split（fileSplitterSpec，spec-> {}）...

spring spring-integration spring-integration-dsl

回答 1 投票 0

登录spring集成Java DSL

java spring logging spring-integration spring-integration-dsl

回答 1 投票 0

Spring集成行业用法

我正在评估新邮件系统的选项。我一直在研究Spring集成，Mulesoft和骆驼。任何框架的关键在于它的行业足迹和支持。我没办法...

spring-integration messaging

回答 1 投票 0

Java spring集成网关请求响应时间记录

我正在使用Spring Integration Gateway公开休息服务。它配置了请求通道和回复通道。我正在寻找可以让我休息的时间的配置...

java spring spring-integration

回答 1 投票 0

无法通过自定义端点配置从S3进行轮询

我尝试使用spring-integration-aws从S3存储桶中轮询以触发spring-batch作业。我的S3存储桶未托管在Amazon上，而是在本地微型服务器上，因此我获得了自定义配置：@ ...

java amazon-s3 spring-integration spring-integration-aws

回答 1 投票 1

Spring boot SFTP，SFTP中的动态目录

我试图将文件上传到动态目录到SFTP。当我上传一些文件时，第一个文件总是上传到最后一个目录。然后，其余文件将被上传到正确的...

spring-boot spring-integration

回答 1 投票 0

Spring集成JMS后期事务确认和提交

我正在使用spring-integration（和启动）来设置会话事务处理的JMS侦听器。但是，我正在观察一个问题，其中消息似乎被确认并延迟了一秒钟提交（即使...

spring-boot jms spring-integration activemq spring-jms

回答 1 投票 0

Spring集成会导致多个bean错误

我正在使用Spring Boot并尝试使用Spring集成（因为我想使用其SFTP客户端）。但是我收到以下错误：描述：com.example.demo.service ....中构造函数的参数0。

spring-boot spring-integration

回答 1 投票 0

线程在调用ImapIdleChannelAdapter.doStop时卡住

我使用spring集成imap-idle-channel-adapter接收电子邮件，但是在接收电子邮件期间似乎线程卡住了，而我们试图停止适配器时，发现存在线程卡住的问题。 ...

spring-integration

回答 1 投票 0

使用ExpressionEvaluatingRequestHandlerAdvice将有效负载推送到远程服务器后，无法删除有效负载

我正在尝试使用ExpressionEvaluatingRequestHandlerAdvice删除已推送到远程服务器的源文件：@Bean公共建议expressionAdvice（GenericEndpointSpec ]] 再一次： public String transform(String filePath) throws IOException { String content = new String(Files.readAllBytes(Paths.get(filePath))); return "Transformed content: " + content; } 因此，您的.transform(transformer, "transform")产生的是String，而不是File。对于Sftp.outboundAdapter()，这是可以的，因为它可以将该字符串转换为远程文件内容。但是，advice.setOnSuccessExpressionString("payload.delete()");对String对象应该做什么？我相信您想删除一个文件，因此您需要完全具有File对象，该建议才能正常工作。 FileReadingMessageSource为我们填充了一个FileHeaders.ORIGINAL_FILE标头。因此，您可以将要删除的表达式更改为此： headers[file_originalFile].delete() 你应该没事。

java spring spring-integration spring-integration-file

回答 1 投票 1

收听带有弹簧集成的TCP提要

我想连接到两个不同的TLS加密的TCP提要，并读取和发送json数据。当然，将以某种方式处理传入的消息。它不一定需要在...

spring-integration

回答 1 投票 0

Spring集成使异步网关等待聚合结果

我正在使用spring集成来处理文件。我想逐行读取文件，过滤，转换并发送到kafka。通过异步网关传递文件进行处理。在处理结束时，I'...

java spring spring-integration spring-integration-dsl

回答 2 投票 0

如何在具有多个工作人员（相同数量的分区）的同一主题上扩展kafka客户应用程序

我想了解如何通过使用来自Kafka的同一主题的消息来扩展应用程序（多个实例）。我的疑问是，如果我有一个包含4个分区的A主题，并且创建了...