Spring integration inboundChannelAdapter意外停止轮询

文章/答案/技术大牛

发布

2回答

ftp、integration、poller

我们的问题是，在找不到新价格的几个小时后，民意测验者就会停止投票。日志文件中没有错误(即使在调试级别上运行在org.springframework.integration上)，也没有异常。我们现在使用单独的TaskExecutor来隔离问题，但轮询器仍然停止。与此同时，我们调整了cron表达式以匹配这些小时数，以限制资源使用，但轮询器仍然会在应该运行时停止。我们在FtpStreamingMessageSource上使用@InboudChannelAdapter，配置如下： @Bean

浏览 31提问于2020-04-06得票数 0

1回答

Spring Integration - @InboundChannelAdapter轮询

spring-integration

我是Spring Integration的新手。我们使用Spring Integration注解创建我们的应用程序。我已经配置了一个@InboundChannelAdapter，轮询器的固定延迟为5秒。但问题是，只要我在weblogic上启动我的应用程序，适配器就开始轮询并访问端点，而实际上没有任何消息。

浏览 76提问于2019-12-24得票数 0

回答已采纳

1回答

如何在kafka宕机时停止@InboundChannelAdapter的轮询，防止数据丢失？

spring-integration、spring-cloud、spring-kafka、spring-cloud-stream、spring-cloud-dataflow

我使用的是spring cloud数据流。@Beanpublic SupplierProductBuilder dataAccess) { }; 如果kafka突然停机，那么我们如何停止这种轮询行为以防止数据丢失预期的性能是在ka

浏览 31提问于2020-12-21得票数 0

1回答

Spring集成:文件轮询内存消耗

spring-integration、poller

我使用轮询器跟踪InboundChannelAdapter每30秒处理一次文件。文件并不大，但我意识到即使没有文件到来，内存消耗也在不断增加。@Beanpublic MessageSource<File> flowInboundFileAd

浏览 6提问于2017-07-11得票数 1

1回答

Spring集成- @ServiceActivator与Poller

spring-integration

我正在从事基于注解的Spring集成项目。我试图用轮询器编写@ServiceActivator，但问题是消息轮询恰好发生了3次，然后就停止了。这里的问题可能是什么？同样的轮询在@InboundChannelAdapter上也能很好地工作，但我想知道为什么它不能在ServiceActivator上工作。

浏览 96提问于2019-12-25得票数 0

回答已采纳

1回答

修复了任务执行器的延迟

java、multithreading、spring-integration、router、splitter

我的项目有一个-spring集成固定延迟轮询器(5分钟)其获得一串记录-将其发送到拆分器，拆分器将记录拆分并在输出通道将它们发送到池大小为2的任务执行器路由器通道，并且发送每个记录以便在服务激活器处进一步处理并在聚合器处接收如何让轮询器在所有记录处理完成后等待5分钟，而不是在拆分器通道上等待5分钟？配置：<integration:channel id="splitterChan

浏览 6提问于2015-06-06得票数 1

1回答

Dispatcher在尝试正常关闭应用程序时没有订阅者

spring-integration

应用程序在docker容器中运行，为了维护或部署的目的，应该可以停止该容器。当容器关闭时，流应该完成将文件写入远程主机，并且不应该接受新的传入文件。} //CHECKSTLYE:ON}timestamp=15:55:56.599, thread=task-scheduler-2, sev

浏览 3提问于2018-12-06得票数 0

1回答

Spring集成如何在JavaConfig中使用控制总线，无需数字用户线路

spring-boot、spring-integration、control-bus

我有一些关于Spring Integration和控制总线的问题。我需要在InboundChannelAdapter上关闭自动启动功能。org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.integration.annotation.InboundChannelAdapter;

浏览 12提问于2020-07-29得票数 1

回答已采纳

1回答

PollerMetadata是空的，当我们在@In界InboundChannelAdapter中使用自定义pollerMetadata时

spring-boot、spring-integration

当我运行我的应用程序bean时，PollerMetadata没有时间在@InboundChannelAdapter之前初始化并抛出异常： metadata.setTrig

浏览 0提问于2019-03-11得票数 0

回答已采纳

2回答

为什么spring cloud stream的@InboundChannelAdapter不接受任何参数？

spring、apache-kafka、spring-integration、spring-cloud、spring-cloud-stream

我正在尝试使用spring cloud stream在kafka上发送和接收消息。这方面的示例使用了一个使用时间戳作为消息的简单示例。当我在上遇到这个拦截器时，我正试图更深入地了解现实世界的应用程序我试着这样使用它： @InboundChannelAdapter但是“带有@InboundChannelAdapter注解的方法不能接受任何参数”。那么你应该如何使用它呢？我知道@InboundChannelAdapter来自<e

浏览 0提问于2017-07-27得票数 0

1回答

如何在Spring集成中使用JAVA配置创建http入站通道适配器？

java、spring、spring-integration、spring-integration-http

如何使用Java Config或Spring DSL进行此配置？<int-http:inbound-channel-adapter supported-methods

浏览 31提问于2021-08-31得票数 1

回答已采纳

1回答

如何使用部署在S3中的spring集成app来优化处理存储在pcf存储桶中的大量文件？

spring-boot、amazon-s3、spring-integration、pcf

我们的应用程序是使用经典的spring mvc(4.x)和spring集成框架开发的，并部署在weblogic中(我们没有其他选择)，它轮询nfs挂载中的文件并对其进行处理。我们现在的问题是PCF没有配置为使用卷服务，所以我们必须像存储一样从S3轮询文件并处理它。

浏览 22提问于2021-01-10得票数 1

回答已采纳

1回答

如何在收到消息后停止轮询？弹簧集成

spring、spring-integration

我想轮询目录中的文件，并在找到文件后停止轮询。我对Spring框架非常陌生，其中很多仍然非常令人困惑。在做了一些研究之后，我发现了几种方法，但他们中的任何一个都没有运气。然而，投票似乎在2秒后就停止了。我不知道如何包含仅在接收到文件时停止的条件。import org.

浏览 8提问于2020-03-15得票数 1

回答已采纳

1回答

来自控制器的Spring批处理集成启动/停止文件适配器

spring-integration

我的最终目标是当我在两个适配器上调用stop时，如果一个文件被放置在入站通道适配器轮询的任何一个目录中，那么该文件将不会被处理。情况并非如此--档案仍在被调查和处理。下面是发出的停止命令：当我在第二个适配

浏览 10提问于2015-08-02得票数 2

回答已采纳

1回答

使用Spring集成的文件轮询

spring、file、integration、using、polling

如何在没有xml配置的情况下使用Spring Integration Api从特定文件目录中轮询多个文件，最好使用基于Java注解的方法？我想要获得轮询的文件列表，遍历它们并进一步处理。这就是要求。@Bean @InboundChannelAdapter(value = "fileInputChannel", poller = @Poller(fixedDelay = "60000

浏览 1提问于2016-08-09得票数 1

1回答

等待spring集成流程完成

java、spring-integration、spring-integration-dsl

我有一个从目录中读取文件并执行一些操作的简单流程： @Bean return IntegrationFlows .id("flow1") .poller(Pollers.fixedDelay(30000)

浏览 20提问于2021-08-25得票数 0

1回答

如何停止轮询InboundChannelAdapter

java、spring-integration、spring-integration-sftp

我使用RotatingServerAdvice从一台服务器的两个不同目录中轮询文件，运行正常，问题是一旦启动inboundtest.start ()，我就不能停止轮询。fileSynchronizer; @EndpointId("inboundtest")

浏览 26提问于2021-09-30得票数 0

回答已采纳

1回答

Spring集成通道卡住了，并且不处理消息

spring、spring-boot、spring-integration、spring-integration-file

最近，我们向spring集成轮询器引入了任务执行器，以加快我们的文件读取过程。然而，引入任务执行器导致了意外的问题，在我们的服务中停止处理spring集成通道中的消息 <?/integration/spring-integration.xsd http://www.springframework.org/schema/integration/

浏览 19提问于2020-08-19得票数 0

2回答

Spring Integration @Scheduled由于@Poller而无法工作

java、spring、spring-integration

我有一个Spring Boot / Spring Integration应用程序正在运行，它在Spring Integration中使用@Poller，并在一个几乎不相关的类中的另一个方法上使用@Scheduled@Poller用于轮询FTP服务器以获取新文件。然而，我发现似乎@Poller以某种方式干扰了我的@Scheduled方法。我发现，如果正在处理这些文件，那么@Scheduler将完全停止触发。@Scheduled设置为每毫秒触发一次fixedDel

浏览 47提问于2020-03-17得票数 0

2回答