在Spring Cloud Stream中有没有MessageQueueMatcher.receivesPayloadThat的替代品？
在Spring Cloud Stream中，没有直接替代MessageQueueMatcher.receivesPayloadThat的功能。MessageQueueMatcher.receivesPayloadThat是用于验证消息队列中接收到的消息负载的断言方法。
然而，Spring Cloud Stream提供了其他方式来验证消息队列中接收到的消息负载。以下是一些可用的替代方案：
- 使用自定义的消息转换器：可以通过实现MessageConverter接口来自定义消息转换器，以便在发送和接收消息时进行自定义的转换和验证。您可以在转换器中添加逻辑来验证接收到的消息负载。
- 使用自定义的消息监听器：可以通过实现MessageListener接口来创建自定义的消息监听器，以便在接收到消息时执行自定义的逻辑。您可以在监听器中添加逻辑来验证接收到的消息负载。
- 使用自定义的消息处理器：可以通过实现MessageHandler接口来创建自定义的消息处理器，以便在接收到消息时执行自定义的逻辑。您可以在处理器中添加逻辑来验证接收到的消息负载。
这些替代方案可以根据您的具体需求和场景进行选择和实现。请注意，以上提到的替代方案都是Spring Cloud Stream提供的通用机制，不依赖于特定的云计算品牌商。
更多关于Spring Cloud Stream的信息和使用方法，您可以参考腾讯云的相关产品文档：Spring Cloud Stream。
相关·内容
我最近切换到了Spring Cloud Stream的新测试绑定器。在我的项目中，我更新到了最新的Spring Cloud Stream版本3.1.3，删除了spring-cloud-stream-test-support依赖之后，MessageQueueMatcher.receivesPayloadThat是否有新的匹配器或具
浏览 11提问于2021-09-15得票数 0
回答已采纳
当我尝试使用Spring Cloud Stream构建Gradle Spring Boot项目时，收到以下错误： Execution failed for task ':compileTestJava> Could not find org.springframework.cloud:spring-cloud-stream:test-binder.Required by:
project : > org.spri
浏览 28提问于2020-12-07得票数 0
回答已采纳
2回答
使用云流测试不起作用
、、、、
我用spring-cloud-stream尝试了一些东西。一切正常，现在我试着写一些测试用例。不幸的是，它们不起作用。Subscriber.CHANNEL) this.lastMessage = message;}spring: stream:
浏览 2提问于2017-07-07得票数 0
:183) ~[spring-cloud-stream-3.0.3.RELEASE.jar:3.0.3.RELEASE]
浏览 5提问于2020-03-25得票数 0
我在应用程序A中有producer，配置如下，spring.cloud.stream.bindings.packageVersionUpdatesPublishChannel.destination=package-version#Consumer Properties:
spring.cloud.stream.bindings
浏览 1提问于2019-05-30得票数 0
我一直在尝试使用Spring Integration的@Router和带有Kafka绑定的Spring Cloud Stream。我的理解是，当您从带有@Router注释的方法返回频道名称的List时，它们应该被生成到目标Kafka主题。但我没有看到正在产生的消息。Spring Integration的@Router可以与Spring</
浏览 16提问于2020-04-06得票数 0
回答已采纳
当Kinesis流使用者遇到错误，并在使用@StreamListener注释的方法中抛出异常时，如何配置绑定以使消息重新排队或发送到DLQ？我在Spring Cloud Stream中看到了对Rabbit和Kafka的这种级别的支持，但我没有看到对Kinesis绑定的支持。在Kinesis流处理器中处理错误的推荐方法是什么？它是如何通过配置和/或代码实现的？
浏览 24提问于2019-05-16得票数 1
回答已采纳
我使用： <dependency> <artifactId>spring-cloud-starter-stream-rabbit我试过这个： spring: config: discovery:
浏览 114提问于2019-12-27得票数 0
回答已采纳
在运行在Kubernetes上的SCDF中，向数据流服务器传递附加参数或环境变量的格式是什么？dataflow-server: container_name: dataflow-server - "9393:9393" - s
浏览 1提问于2021-08-06得票数 0
回答已采纳
我正在努力寻找任何关于我可以在哪里使用Spring Cloud Streams的文档，这些文档将Kafka主题放入KTable中。在使用注解在Spring boot中执行此操作的过程中，我已经查找了文档，例如这里的https://cloud.spring.io/spring-cloud-static/spring-c
浏览 19提问于2021-04-22得票数 0
2回答
我有一个主题，在我的流处理器中有多个分区，我只想从一个分区中流式传输它，并且可以弄清楚如何配置它spring.cloud.stream.bindings.input.destination=uinput
spring.cloud.
浏览 1提问于2019-02-16得票数 0
是否提供通过在cloud.stream @Input("suffix"+"SampleQueueA")和@Input("suffix"+"SampleQueueB")中动态更改队列名称来在两个“队列”之间推送消息 使用消息服务器RabbitMQ的Sprig cloud stream的用例。我尝试通过动态更改队列名称将消息推送到两个不同的队列中。: gues
浏览 27提问于2019-05-26得票数 0
基于其中一个官方示例，我正在试用的一个简单的spring引导应用程序由于一个奇怪的错误而失败了。我在spring-integration 5.2.3.RELEASE.jar中看到了org.springframework.integration.core.Pausable (即在不同的包中)。这个例子在
EDIT #1: I'm unable to find Hoxton.BUILD-SNAPSHOT version of spring
浏览 4提问于2020-04-27得票数 2
1回答
我刚刚开始学习和Dataflow，我想知道一个重要的用例。我创建了示例处理器乘法器，它接收消息并将其重发5次输出。，在第五次发送处理器之前，这个处理器会崩溃。我想要实现的是在DLQ中支持输入消息，在之前发送的4条消息被恢复，并且不被下一个操作数使用(就像在正常的JMS事务中一样)。我已经尝试在我的处理器项目中定义以下属性，但没有成功。spring.cloud.stream<
浏览 0提问于2016-08-18得票数 2
回答已采纳
我在application.properties中有配置：spring.cloud.stream.bindings.some-channel1.group=a-queue
spring.cloud.stream.rabbit.bindings.some-channel1.cons
浏览 0提问于2018-05-25得票数 1
我正在尝试在spring cloud stream中实现延迟消息(不使用rabbitmq插件)，但它不起作用spring</
浏览 18提问于2019-08-14得票数 0
我正在使用spring云流并试图发布avro消息，但是得到了上述异常，spring.cloud.stream.bindings.feed-output-channel.producer.useNativeEncoding=truespring.cloud.strea
浏览 14提问于2022-01-21得票数 0
回答已采纳
我使用的是Spring Boot2.1.1.RELEASE和Spring Cloud Greenwich.RC2，spring-cloud-stream-binder-kafka的托管版本是2.1.0RC4spring.cloud.stream.bindings.input.group=consumer-gp-1spring.cloud.stre
浏览 29提问于2019-03-18得票数 2
使用Spring for Apache Kafka或Spring AMQP，我可以实现消息发布/订阅。Spring Cloud Bus使用kafka/rabbitmq来做大致相同的事情，它们之间有什么区别？
浏览 11提问于2018-08-01得票数 4
2回答
但是在zipkin服务器中，只有Service3中的spans可用。Service4没有span显示。Marshal跨越Spring云流绑定器compile('org.springframework.cloud:spring-cloud-sleuth-stream') compile('org.springframework.cloud:spring-cloud-<em
浏览 9提问于2017-02-22得票数 0
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
腾讯云开发者
