测试SpringCloudStream使用者的最小上下文

文章/答案/技术大牛

发布

1回答

rabbitmq、junit5、spring-cloud-stream

我正在尝试创建junit测试，这是一个利用Spring Cloud Stream从RabbitMQ接收事件的应用程序。在其他应用程序中，我通常导入spring-cloud-stream-test-support和spring-rabbit-test，并用@SpringBootTest注释测试类，这样就可以了。然而，@SpringBootTest加载了整个应用程序上下文，这在此应用程序中并不理想，因为它非常大，并且需要模拟太多与测试无关的bean。因此，我尝试通过指定我想要加载的<

浏览 13提问于2021-05-13得票数 0

回答已采纳

2回答

允许禁用云流的配置？

apache-kafka、spring-cloud-stream、dynamic-loading、spring-cloud-stream-binder-kafka

我希望这个应用程序以application.yml启用的模式运行，也就是说，如果用户只想为http请求启用它，那么kafka就不应该连接。我可以通过使用@KafkaListener的以下属性禁用自动配置，从而使用普通的spring启动kafka插件来实现这一点，现在，我们正在尝试移动到云流，而我发现通过删除云流和绑定程序库来禁用云流的唯一方法。是否有更好的方法使用自动配置模式下的属性禁用它，或者是否有可用

浏览 2提问于2020-05-12得票数 3

1回答

Spring @StreamListener条件不推荐替代方案

java、spring-boot、apache-kafka-streams、spring-cloud-stream、spring-cloud-stream-binder-kafka

我们让多个应用程序使用者收听相同的kafka主题，并且生产者在向主题发送消息时设置消息头，以便特定实例能够评估标头并处理消息。TestObj message) {} 在SpringCloudStream3.0.0中，@StreamListener被废弃了，我无法在函数中找到与条件属性等价的内容。

浏览 11提问于2021-09-16得票数 5

1回答

如何在每次测试后断开与rabbitmq的连接？

spring、amqp、spring-test、spring-amqp、spring-rabbit

有两个SpringRunner测试断言amqp接收器是否接收到消息。测试连接到在单独进程中运行的rabbitmq代理。问题是，应用程序上下文在第一次测试时加载并将使用者注册到队列，但在测试完成后没有断开连接。当第二个测试运行时，它的应用程序上下文也会注册一个使用者，但作为第二个测试的一部分发送到交换的任何消息仍然会到达由第一个测试</em

浏览 6提问于2019-07-18得票数 1

1回答

当使用3.0.3.RELEASE时，我可以应用优雅的关机吗？

spring-boot、apache-kafka、spring-cloud-stream

我开发了基于SpringCloudStream3.0.3.RELEASE的kafka消费者应用程序。(SpringBoot 2.3.4 developed )春云流默认为此工作吗？那有相关的文件吗？关于您的信息，我使用的春天云流卡夫卡如下。

浏览 2提问于2021-05-20得票数 3

2回答

多个没有将状态传递回上下文的子级(只有最后一个子项可以)

javascript、reactjs、react-hooks、react-context

我希望有一种方法来记录所有子元素的状态，因此尝试使用上下文提供程序来保存这些信息。我的目标是在

浏览 9提问于2022-09-09得票数 2

回答已采纳

1回答

如何禁用用户

apache-kafka、spring-cloud-stream

以下是我的情况：我想知道在绑定层上是否有任何设置可以阻止它的启动。

浏览 3提问于2021-12-06得票数 2

回答已采纳

1回答

如何从Java Spring使用者应用程序调用Java Spring实用程序jar

java、spring、maven

我是Spring的新手，我试过用谷歌搜索这个，但我没有找到任何实用的指导。我有一个Maven Spring实用程序，它有自己的Spring configuration.xml。我希望其他消费应用程序(很可能还有Maven和Spring )通过将它包含在它们的类路径中来调用该实用程序，并且只需进行最小限度的调整，就可以让该实用程序应用程序工作。总之，我希望有一个包含我的实用程序代码和Spring xml文件的jar，然后将该jar放在使用者</

浏览 0提问于2015-03-10得票数 0

1回答

Redux如何使组件的重呈现最小化？

reactjs、redux、react-redux

这是一个关于React / Redux的高级问题。似乎我可以在一个上下文(作为上下文使用者)的基础上制作我的应用程序的每个组件，并且使用这个上下文作为唯一的数据存储。但是，当上下文发生变化时，我的应用程序的每一个组件都会重新呈现--这是不可取的。是通过让Connect成为上下文使用者，而不是让我们的

浏览 2提问于2020-02-25得票数 0

1回答

Unix用户空间中的实时IPC

c++、unix、real-time、ipc、producer-consumer

我想为以下问题寻求最佳方法:我有两个截然不同的过程:生产者和消费者。生产者产生项目，其中每个项目都是一个无符号整数。而消费者对它们的消费，与普通消费者生产者的问题不同的是，消费者需要知道物品生产的确切时间。消费者不能信任生产者，所以生产者不应该将时间与商品一起提供，这迫使消费者在消费商品的那一刻向系统询问当前时间。由于生产者是一个实时应用程序，所有这些都需要在对生产者尽可能少的影响下执行。我试着阅读Unix中的IPC机制，但我没有找到可以满足这些限制的</em

浏览 0提问于2017-05-31得票数 2

1回答

春季云流卡夫卡停顿/恢复绑定

java、apache-kafka、spring-cloud-stream、spring-kafka、circuit-breaker

我们已经实现了一个断路器，它停止应用程序上下文，用于目标系统(DB或第三方API)无法执行的情况，如下所示：是否有可能从代码中控制绑定器生命周期，意味着在目标服务器关闭的情况下，pause绑定器，以及当它启动时，到resume

浏览 0提问于2018-11-26得票数 2

1回答

在正文中发现嵌入式报头

spring、apache-kafka、kafka-consumer-api、spring-cloud-stream、spring-kafka

我使用SpringCloudStream1.3.2.RELEASE向Kafka发布字符串消息。当我使用命令行Kafka使用者或Spring @KafkaListener使用消息时，总是会将一个contentType头追加到消息正文中。有什么方法可以摆脱嵌入的头吗？--private void send() { channel.test().send(MessageBuilder.withPayload("{\"foo\":

浏览 1提问于2018-05-15得票数 0

回答已采纳

1回答

如何在NUnit测试中实现静态“测试本地”数据？

c#、nunit、nunit-3.0

对于一个库，我有几千个NUnit测试，其中许多测试依赖于一些静态可用的“请求上下文”，该上下文的作用域是所服务的请求并跨任务流动。库使用者提供检索当前请求上下文的实现。我需要实现一些东西来为我们的NUnit测试项目提供这个上下文，其中上下文的作用域是每个单独的测试运行；每个测试</em

浏览 1提问于2018-04-06得票数 2

回答已采纳

1回答

上下文使用者可以通过Orion检索实体的历史值吗？

fiware-orion、fiware-cygnus、fiware-sth-comet

我是Fiware技术的新手，我读过许多关于Orion上下文代理的文档，但我不清楚上下文使用者是否可以从Orion Context Broker请求有关实体的历史值。我的意思是，如果上下文使用者需要从第1天到第10天从单个温度传感器进行分析，那么它能从Orion请求这些值还是上下文使用者只能从存储的数据库中检索这些值？猎户座有这种能力吗？

浏览 2提问于2018-06-27得票数 1

回答已采纳

1回答

本机编码问题:有效载荷不是byte[]

spring-integration、avro、spring-kafka、spring-cloud-stream

由于我们已经在我们的使用者(SpringCloudStream2.2)上启用了本机解码，从而使我们的应用程序与其他工具集成起来，因此出现了以下错误：spring: kafka: input: consumer

浏览 1提问于2019-08-14得票数 0

回答已采纳

1回答

在释放EntityFramework时使用DbContext导航属性

c#、entity-framework、idisposable、dbcontext

我的服务类(在ASP.NET MVC应用程序中)中的当前检索模式如下所示：{ }其中，_repoFactory.Get<T>()返回一个存储库，该存储库在处理时也会处理实体框架DbContext；但是，当Get(int id)方法的使用者需要对Client对象使用导航属性时，会引发异常，因为上下文已经被释放。我可以预见一些解决

浏览 1提问于2013-11-13得票数 3

回答已采纳

1回答

实体框架代码优先与生产者/消费者模式

entity-framework、entity-framework-4、ef-code-first

我正在实现一个生产者/消费者模式：这些对象首先使用与生产者线程关联的上下文使用实体框架代码进行物化。 使用者线程需要自己的上下文。是否有可能将物化对象(每个

浏览 4提问于2012-07-21得票数 2

回答已采纳

1回答

将根组件包装在<Provider>中，或将自定义React提供程序传递给<Provider>，并将相应的React使用者传递给Connect

reactjs、unit-testing、redux、react-testing-library

我想通过单元测试来测试组件，我不知道如何将组件呈现给，它会出错。我只能使用"React-testing-library“ 

浏览 3提问于2021-08-17得票数 2

2回答

对于所有消费者，我会有一个域模型(.NET项目)还是每个使用者有一个域模型(.NET项目)？

c#、domain-driven-design、domain-model

假设我有一个名为“Loans”的有限上下文和以下API：NatWest上述三家银行都是消费者，拥有API。我使用的是散射聚集模式(https://www.enterpriseintegrationpatterns.com/patterns/messaging/BroadcastAggregate.html)我相信每个使用者应该有一个域模型，因为域逻辑只与该使用者相关。与其说这是一个真正的商业问题，不如说这是一个经过

浏览 0提问于2019-06-05得票数 1

2回答

实体框架4.0单元测试

unit-testing、entity-framework、testing

我已经按照本文的思路实现了单元测试，在EF4中使用伪对象上下文和POCO实现了IObjectSet。但是我不确定如何在我的伪对象上下文中实现几个方法来进行测试。我的object context接口上有CreateQuery和ExecuteFunction方法，这样我就可以执行ESQL和存储过程，但我不能(轻松地)在伪对象上下文中实现它们。另一种方法是使用我的存储库的两倍测试，而不是这里建议<em

浏览 0提问于2009-12-29得票数 7

回答已采纳

点击加载更多