使用Java DSL的Spring批处理集成配置
Spring Integration Java DSL Reference和Spring Batch Java配置文档说明了如何将Java配置用于Spring Integration和Spring Batch。
但它们没有说明如何为Spring批处理集成配置它。如何使用DSL配置JobLaunchingGateway？
干杯，曼诺
共有1个答案
JobLaunchingGateway是一个MessageHandler，因此您可以将它定义为@bean并在流程中的.handle()方法中使用它。
-
我有一个spring批处理应用程序，它从文件中读取数据，进行一些处理，最后编写一个定制的输出。这一切都是一步到位的。在下一步中，我将使用一个tasklet来归档输入文件（移动到另一个文件夹）。这个应用程序运行良好。但是，现在我需要在远程服务器上对sftp输出文件进行进一步处理。我找到了一种使用spring integration实现sftp的方法，在这里我创建了一个输入通道，该通道将反馈给outb
-
在spring integration (Java DSL)中，如何定义一个完整流程的事务？ 通过Spring集成，我们可以定义一个示例流程： 我需要一个跨度整个流程的交易。目前，当我使用“aMessage转换器”访问数据库时，事务将在处理完此消息转换器后关闭。但是我需要一个在处理“另一个消息转换器”时仍未提交的事务？ 我希望只需添加一个“@Transactional”（或@Transaction
-
我是Spring的新人。最近我试着让Spring批处理和Spring集成一起工作。我想有一个JobListener，它会监听消息到达特定的频道并启动Spring批处理作业。 我在github上找到了一个例子(https://github.com/chrisjs/spring-batch-scaling/tree/master/message-job-launch)我试图以某种方式将Spring批处
-
当RabbitMq消息到达队列时，我目前正在使用IntegrationFlow来触发作业执行。IntegrationFlow的AmqpInFronChannelAdapter和作业的第一步的ItemReader都配置为从同一队列中读取消息。 我遇到的问题是IntegrationFlow的AmqpInboundChannelAdapter读取RabbitMQ消息，然后ItemReader再也找不到该
-
我正在尝试将BeanIO与spring Batch集成。使用BeanIO，我正在读取一个固定长度的流文件。我已经测试并验证了使用独立类读取平面文件的代码，它可以无缝地工作，但是当我试图将它与Spring Batch集成时，BeanIOFlatFileItemReader的doRead（）方法没有被调用，而且我编写的RedemptionEventCustomProcessor是如何直接被调用的。 我
-
我能有一份只有奴隶而没有主人的工作，听rabbitmq队列吗？我想在spring boot应用程序中使用spring批处理和spring集成来侦听队列并以面向块的方式处理消息。 我想使用Michael Minella（https://www.youtube.com/watch?v=30Tdp1mfR0g）在Spring批处理的远程组块示例中解释的配置，但没有主配置。 下面是我的工作配置。 下面是我