我想做两个Spring Boot应用的集成测试，这两个应用也在使用Spring integration flows。要测试我的应用程序，我想检查通过myMessageChannel路由的消息。我如何窃听我的直接消息通道，并将消息重定向到PollableChannel，以便我可以逐个阅读它们？我在网上找到的方法对我都不起作用。TestPropertySource("classpath:integration.properties")
public class MyWir
浏览 0提问于2018-01-04得票数 2
回答已采纳
我正在用一个新的spring集成版本测试我现有的应用程序。-1.2.1.RELEASE.jar:na] at org.springframework.integration
浏览 3提问于2017-01-27得票数 3
回答已采纳
我在我的应用程序中使用Spring Boot Java。应用程序正在使用MessageChannel向Kafka发送一些消息。例如:this.messageChannel.send(消息)。我想在集成测试中模拟这个消息通道调用，这样消息就不会发送到Kafka。目前正在使用Wiremock进行Spring集成测试。 请给我建议模拟MessageChannel发送方法的方法
浏览 27提问于2021-08-06得票数 0
我正在做一个基于注解配置的Spring集成项目。我们从另一个团队继承了这个项目，并试图找出ThreadPoolTaskExecutors是否被正确使用。());public MessageChannel outputChannel() { businessTaskExecutor()); .add
浏览 13提问于2020-09-15得票数 1
正如Spring Integration文档()所述，如果我们想让窃听以异步方式运行，我们需要将消息发送到异步通道(可轮询通道或执行器通道)returnIntegrationFlows .wireTap(customChannel())
浏览 3提问于2017-05-30得票数 0
我正在尝试spring集成中的Java。我在监听一个频道。CustomGtwy service = ctx.getBean(CustomGtwy.class); public MessageChannelloggerChannel(){ }
public MessageChannel pus
浏览 1提问于2015-07-10得票数 1
回答已采纳
1回答
但是如果我添加简单的wireTap行public IntegrationFlow routerFlow() { at org.springfra
浏览 1提问于2017-07-17得票数 2
回答已采纳
1回答
使用者是一个spring集成项目，它从消息队列中消耗，并进行大量的处理。目前，它是单线程的，无法与生产者发送消息的速率相匹配。因此，队列的深度不断增加。Jms.messageDrivenChannelAdapter(Jms.container(this.emsConnectionFactory, this.emsQueue).get()))
.wireTapJms.messageDrivenChannelAdapter(Jms.container(this.emsConnectionFactory, this
浏览 3提问于2020-01-27得票数 0
回答已采纳
我们计划将代码从迁移到DSL。在XML版本中，我们使用通道名称模式进行跟踪。如何在Java中实现这种或更简单的操作。
浏览 4提问于2015-07-22得票数 1
回答已采纳
1回答
IntegrationFlows： .from(yieldCurveConversionResultChannel) .get();
在wireTap
浏览 10提问于2021-03-26得票数 1
回答已采纳
我们在同一个应用程序中使用了具有多个处理程序的Spring cloud stream，我们正在尝试创建一个集成测试。问题:我们需要检查整个流程，因此在测试用例中，如果Source1生成了数据，那么它应该在Sink1中可用。如何测试？我们检查了这个文档(https://cloud.spring.io/spring-cloud-static/spring-cloud-stream/2.2.0.RELEASE
浏览 24提问于2019-12-27得票数 1
我需要在我的Spring Integration上下文中将消息动态分配给MessageChannels。当我知道我想要的MessageChannel的名称时，我可以通过从上下文中获取MessageChannel bean来实现这一点。但是，MessageChannel应用编程接口没有与之关联的getName()或getId()方法。提前谢谢。
浏览 0提问于2014-01-30得票数 0
1回答
我正在尝试创建一个简单的测试来检查错误通道从流通道获取消息MessageChannel processingStart() {return new DirectChannel();MessageChannel channelError() {}
代码运行良好，但在创建测试时遇到了一些问题--我向processingStart通道发送
浏览 4提问于2022-10-14得票数 0
回答已采纳
我是spring集成的新手。我正在为我们的项目评估Spring Integration。我遇到了一个关于如何处理异常的问题。 @Bean
Messag
浏览 45提问于2021-03-14得票数 0
回答已采纳
我试图知道消息是否通过特定的通道进行测试，或者我想从特定的通道获取消息 private finalreplySubmitApplicationChannel")管道MessageChannelsubmitApplicationChannel() {
return new Dir
浏览 1提问于2021-06-03得票数 0
回答已采纳
2回答
implements MessageHandler {
@Qualifier("receiveChannel") .getLog(EmailService.class);
messageChannel.subscribemessage) throws MessagingExcep
浏览 2提问于2014-01-15得票数 0
回答已采纳
1回答
validate, "buildPreCheck").handle(getOffersProcessor)**.wireTap它仍然将WireTap节点执行为Sequencal并等待该节点。
请帮助使它成为一个Aysnc节点。
浏览 0提问于2018-09-01得票数 1
回答已采纳
我有兴趣了解spring集成标记中使用的类，这样我就可以通过类的javadoc获得更多的标签细节。我有两个基本问题：
<?xml version="1.0" en
浏览 2提问于2016-07-08得票数 1
回答已采纳
我必须使用xmls中的Spring集成将一个项目转换为Java，并在下面进行了尝试，但我得到了一些异常。下面是Spring配置 <int:channel id="channel_2"/> return new DirectChannel(); @Bean
public <e
浏览 3提问于2016-03-30得票数 2
回答已采纳
我们是否有示例或开箱即用的支持来使用Spring (不是基本的Spring)，而不是像链接中那样有口水的骆驼任何基本设置的指点都很感激。
浏览 5提问于2015-02-09得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
