可以在我的Service Activator上触发两个outputchannel吗？@ServiceActivator(inputChannel = Constants.CHANNEL_INPUT,
outputChannel = Constants.CHANNEL_OUTPUT
浏览 25提问于2019-11-07得票数 0
回答已采纳
我正在从事基于注解的Spring集成项目。我试图用轮询器编写@ServiceActivator，但问题是消息轮询恰好发生了3次，然后就停止了。这里的问题可能是什么？同样的轮询在@InboundChannelAdapter上也能很好地工作，但我想知道为什么它不能在ServiceActivator上工作。@ServiceActivator(inputChannel = "inputChannel", outputChannel = "o
浏览 96提问于2019-12-25得票数 0
回答已采纳
1回答
我使用的是Spring集成框架，其中输入通道是kafka，输出是jdbc。 发生什么:在JdbcMessageHandler中发生错误，outputChannel -> DirectChannel @ServiceActivator(input
浏览 0提问于2021-04-22得票数 1
2回答
我正在Spring中动态创建子()上下文，我希望将每个上下文记录到一个分离的文件中。这个是可能的吗？…
LOGGER.error(“TES
浏览 0提问于2016-11-09得票数 4
在我的应用程序中，我使用多个spring集成通道。MyFirstRepository myFirstRepository;
@ServiceActivator(inputChannel = "my-first-servie-input-channel",
outputChannel = "m
浏览 4提问于2016-10-14得票数 0
回答已采纳
我正在做一个基于注解配置的Spring集成项目。我们从另一个团队继承了这个项目，并试图找出ThreadPoolTaskExecutors是否被正确使用。()); .addInterceptor(new WireTap(eventTrackerChannel())); return new ExecutorChannel
浏览 13提问于2020-09-15得票数 1
我有一个服务器和多个客户端，服务器将发送响应并等待确认，另外我还想永久保存这个连接，以便下一条消息和确认，我应该如何在Spring中创建这些连接。我读过关于Spring集成的文章，我无法找到保持连接的解决方案。clientConnectionFactory.setSingleUse(true); }
@ServiceActivatorDirectChannel();
浏览 2提问于2016-09-01得票数 1
回答已采纳
我认为从的角度来看，响应应该更重要，因为响应实际上是为消息通道提供信息。我说的对吗？HTTP入站适配器用作消息端点(实际上是消息起始点)，它调用一个HTTP请求( REST服务的URL，比方说"“)，向SI消息通道提供它的结果。是那么回事吗？) .channel("transfer_next_channel")}
@ServiceActivator
浏览 3提问于2021-09-01得票数 1
回答已采纳
目前，我有一个工作的spring集成项目，它将消息发送到ActiveMQ的队列的一个实例。在处理程序为JMSSendingMessageHandler.java的情况下，它使用serviceActivator作为端点。但是现在我想要向多个ActiveMQ实例发送消息，这些实例将在配置文件中进行配置。在spring Integration中，没有现成的解决方案可用。我的需求示意图如下：
我需要找出，如何在运行时创建多个服务激活器。
浏览 1提问于2017-03-03得票数 1
我们在我的应用程序中使用Spring集成。我想把一些对象放到通道中进行异步处理和错误处理。为此，我为MessageGateway配置了错误通道和PollableChannel，用于处理要处理的对象。这如预期一样工作-调用此方法是非阻塞的，消息被处理并被转发到下一个通道。但是，当处理方法抛出异常时，它不会重定向到错误通道。密码@Component @ServiceActivator(inputChan
浏览 2提问于2016-11-02得票数 3
回答已采纳
2回答
持久化工作流
、、
我试图用Spring集成实现以下工作流：
@Transformer(inputChannel = "consulAgentSelfChannel", outputChannel但是现在，我不想将对象写入文件中，而是将其存储在带有spring-data-
浏览 4提问于2015-12-19得票数 3
1回答
如果收到某个主题的电子邮件，应该在UI上通过推送消息通知用户。对于整个电子邮件处理，我实现了来自Spring集成的电子邮件/消息处理，这也很有效。在Spring Application上下文中通过@Configuration和@Bean注释生成两个Bean (IntegrationFlow和ServiceActivator)，如下所示：
@Configuration但是，如何在EmailReceiver.processNewEmail方法中将回调集成到Vaad
浏览 28提问于2021-06-08得票数 0
当客户端断开连接时，我们触发一个额外的进程，该进程运行在数据库中的所有数据之上。
问题是当客户端发送数据，我们开始处理数据，然后客户端断开连接，出站适配器(？)尝试将该进程的响应发送回客户端。在我的本地机器上运行它运行良好。当将其部署到运行Corretto 11的Amazon 2实例上的AWSElasticBean秸秆时，它会失败，出现以下错误。(inputChannel = "sendAcknowledgement", outputChannel = "doProcessing")
浏览 2提问于2020-11-17得票数 1
我正在尝试将Spring Cloud Stream应用程序Chelsea.SR1迁移到Horsham。此项目没有绑定器，但使用spring消息传递和集成来集成自定义源和接收器。如何在没有AggregateApplicationBuilder的情况下绑定源代码、转换器和接收器？ &l
浏览 1提问于2019-12-13得票数 0
. -> foo -> [outbound channel adapter] -> bar
我如何编写我的spring集成应用程序，以便foo可以使用一个额外的对象，该对象不是[outbound channel我的应用程序基本上是从AWS SQS接收消息(使用spring-integration-aws)，执行一些过滤/转换，然后将消息发布到Apache Kafka (使用spring-integration-kafka假设我正在使用spring-integr
浏览 54提问于2018-12-15得票数 1
回答已采纳
1回答
. >
<queue capacity="10"/> output-channel="outputChannel
浏览 0提问于2015-01-23得票数 1
回答已采纳
1回答
输出信道路由
、、、
我正在尝试将Spring集成流从XML重写到Java。RoundRobinRouter { /* implementation */}@ServiceActivator(inputChannel = "sendData",
outputChannel = "
浏览 7提问于2016-09-24得票数 0
回答已采纳
我想从ftp服务器读取文件，然后保存到本地存储库，从服务器删除，运行读取文件的作业，在DB上找到一条记录，更改一个参数并保存它。 @Bean
public FtpInboundFileSynchronizer ftpInboundFileSynchronizer(DefaultFtpSessionFactorymessageHandler.setOutputChannelName("jobLaunchRequestChannel"
浏览 2提问于2020-03-04得票数 0
回答已采纳
2回答
我一直在阅读许多Spring和相关文档，以便生成一个将在我的组织的Cloud部署中运行的数据摄取解决方案。这些记录似乎有一个唯一的ID，所以我可以这样对记录进行改进，但我只是不确定如何在DataFlow中最好地实现这种逻辑。据我所知，没有提供这种开箱即用的服务.我读到了Spring的，但我也不确定这是否能解决我的担忧。或者，我可以在Spring中实现这一切，将其作为一个批处理操作来实现，该批处理操作基于某些时间表触发。
对于DataFlow应用程序来说，最好的方法是什么？像我前面在数据流/流&#
浏览 6提问于2017-08-14得票数 1
回答已采纳
1回答
Spring集成中多SFTP主机的处理问题是我不想创建多个Java文件。factory.setAllowUnknownKeys(true);
}
@ServiceActivatorreplyChannel = "fromSftpReadChanne
浏览 2提问于2019-02-12得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
