我有一个Spring Boot应用程序，它使用Spring Cloud Config刷新其属性。我可以很容易地用@RefreshScope刷新我的控制器，但是我不确定如何对我的poller做同样的事情来重新启动我的Spring Integration作业。/refresh，执行器会检测到更改，但我的poller不会获取任何信息。main(String[] args) {
浏览 10提问于2018-08-18得票数 0
回答已采纳
1回答
spring.integration.poller.fixed-delay
spring.integration.poller.cron那么，我如何使用cron表达式呢？集成轮
浏览 13提问于2022-04-27得票数 1
回答已采纳
关于spring集成，如何横向扩展文件轮询？ 假设为5s设置了一个文件轮询器来挑选.tif文件，并且spring集成代码作为引导项目运行在一台服务器上。该preventDuplicate()对文件poller有效。如果使用相同的代码部署另一台服务器，会发生什么情况？如果文件被两个服务器轮询，一个接一个，同一个文件被处理两次，如何
浏览 8提问于2019-02-26得票数 1
我正在从事基于注解的Spring集成项目。我试图用轮询器编写@ServiceActivator，但问题是消息轮询恰好发生了3次，然后就停止了。这里的问题可能是什么？同样的轮询在@InboundChannelAdapter上也能很好地工作，但我想知道为什么它不能在ServiceActivator上工作。@ServiceActivator(inputChannel = "inputChannel", outputChannel = "outputChannel&
浏览 96提问于2019-12-25得票数 0
回答已采纳
1回答
我们有一个spring-boot应用程序(spring-boot-starter-parent-2.0.0.RELEASE)，它使用spring-cloud-starter-zipkin将“span”写入我们也使用了spring-integration (通过spring-boot-starter- integration )，并且我们已经添加了一个带有PollableChannel的集成流，以便在轮询器中使
浏览 0提问于2018-07-20得票数 0
如何使用java dsl集成流从spring集成中触发spring批处理作业。我有下面的代码来轮询目录中的文件，当一个新文件被添加到目录时，就会生成一条消息，我想在那个时候触发一个spring批处理作业。敬请指教。@Bean
public IntegrationFlow inboundFileIntegration(@Value("${inbound.file.poller.fixed.delay}") longp
浏览 2提问于2018-01-23得票数 1
1回答
我正在对由两个集成流组成的春季集成过程进行集成测试。测试定期检查文件夹内容，如果它在预置超时之前设法在文件夹中找到文件，测试就会成功。有时，测试会在poller事务有时间提交之前找到该文件并开始关闭Spring上下文，在这种情况下，我的测试将死得可怕，并以最后的“不能提交JDBC事务，数据库不再可用”
浏览 3提问于2020-03-02得票数 0
1回答
我想为我的spring集成工作流创建一个自定义轮询器。有没有办法在poller上提供自定义实现？我需要根据应用程序当前的工作负载更改每次轮询的最大消息数。
浏览 0提问于2016-01-20得票数 0
3回答
我需要做的是：
基本上这就是我所需要的。我正在考虑使用Spring的task:scheduled-tasks，但我看不到手动启用/禁用任务和设置超时的选项。需要传递到轮询机制的数据可以存储在Spring中。
浏览 1提问于2012-12-31得票数 0
message) -> message.getPayload().getInMessage().getMessageId()),
c -> c.poller5.1.1版本中编写的等效代码(spring-integration-core)。在尝试不同的方法(其中包括为每个消费者调用一次enrichHeaders或使用桥方法)时，我得到了以下异常： java.lang.IllegalArgumentException: A poller should如果我正确
浏览 21提问于2019-02-06得票数 0
我正在查看一些基于spring集成的代码，并且我注意到所有int:入站-网关都使用可轮询请求通道： <int:queue capacity="100" />在配置中指定了显式轮询<e
浏览 2提问于2015-04-13得票数 3
回答已采纳
我有一个从Runnable实现的轮询器。轮询器将自身传递到ScheduledExecutorService中。因为我需要不同的延迟时间取决于任务，所以我使用'schedule‘而不是'scheduleWithFixedDelay'，这有一个问题……
不幸的是，这个轮询器不能正常关闭...日志显示:开始时，'main‘线程调度一个轮询器；之后，'poller18’(或任
浏览 0提问于2012-01-19得票数 0
回答已采纳
我们在一个项目中使用了spring batch和集成 我们使用spring集成来轮询和监视目录；当一个文件进入目录时，我们记录并移动到另一个目录。这就是我们监控的方式 @Bean
@InboundChannelAdapter(value = "fileChannel", poller = @Poller(fixedDelay = "1000sourceReader.setFilter(new S
浏览 16提问于2021-04-22得票数 0
2回答
我是的新手，我正在考虑使用它来轮询目录中的新文件，以便处理这些文件。这是可能的吗?有人能告诉我如何启动Spring的官方文档的相关部分吗？
浏览 3提问于2012-07-27得票数 4
回答已采纳
我是Spring Integration的新手，对于如何结合使用轮询器和消息的事务支持以及max- messages -per-poll值有一个问题。当使用具有以下配置的轮询器时 <int:transactional transaction-manage
浏览 7提问于2013-10-01得票数 1
我需要在我的spring集成流程中处理某些错误情况。我的流程是使用消息存储并在轮询器上设置错误通道。channel>
<int:pollerfixed-rate="50"
error-channel="myE
浏览 1提问于2015-04-20得票数 2
使用spring集成和zookeeper，可以实现一个领导者来执行诸如轮询之类的活动。 }
@InboundChannelAdapter(channel = "fooIncomingEvents", autoStartup = "false", poller
浏览 1提问于2018-12-22得票数 1
1回答
我一直在使用Spring并处理项目中的所有XML文件。不幸的是，它还使用了Spring集成，根据我的经验，这是非常基于XML的。我有一个场景，它要求我有一个聚合器，并让这个聚合器对每一个x数秒进行轮询。<!-- if the
浏览 2提问于2016-11-22得票数 0
回答已采纳
2回答
我正在执行一个spring引导项目，我需要为从某个位置轮询文件添加Spring集成计票器，并在该文件上运行spring批处理来处理它。@Bean
@InboundChannelAdapter(value = "fileInputChannel&quo
浏览 12提问于2016-10-07得票数 0
回答已采纳
我的目标是，如果出现几个异常情况，则让spring集成计票器退出轮询。outbound-channel-adapter id="adapter" ref="handler" <int:poller> 现在，
浏览 2提问于2015-03-12得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
